Java的concurrent包里面的CountDownLatch其实可以把它看作一个计数器，只不过这个计数器的操作是原子操作，同时只能有一个线程去操作这个计数器，也就是同时只能有一个线程去减这个计数器里面的值。 你可以向CountDownLatch对象设置一个初始的数字作为计数值，任何调用这个对象上的await()方法都会阻塞，直到这个计数器的计数值被其他的线程减为0为止。 CountDownLatch的一个非常典型的应用场景是：有一个任务想要往下...
1 package test_6_1;2 3 import java.util.Date;4 5 public class BankAccount {6 7 /**8 * 设计一个BankAccount类，实现银行某账号的资金往来账目管理，包括建账号、存入、取出等。9 * BankAccount类包括，账号（BankAccountId）、开户日期Date(日期)，Rest(余额)。 10 * 另有一个构造函数和三个成员函数BankIn()(处理存入账)，BankOut()处理取出账和一个负责生成账号的自动增长的函数。 11 */ 12 1...
1 package test_4_2;2 3 public class CountsOfUnevenNum {4 5 public static void main(String[] args) {6 7 /** 求0，1，2，3，4，5，6，7所能组成的8位奇数个数。 */8 9 int[] numArray = {0, 1, 2, 3, 4, 5, 6, 7}; 10 11 int unevenNum = countUneven(numArray); 12 int zero = countZero(numArray); 13 int midNum = numArray.length - zero - 1; 14 ...
1 package test_2_2;2 3 import java.util.Scanner;4 5 public class CountBonus {6 7 public static void main(String[] args) {8 /** 企业发放的奖金根据利润提成。利润(I)低于或等于10万元时，奖金可提10%；9 * 利润高于10万元，低于20万元时，低于10万元的部分按10%提成，高于10万元的部分，可提成7.5%； 10 * 20万到40万之间时，高于20万元的部分，可提成5%；40万到60万之间时高于40万元的部分...
前言 相信大家都挺熟悉 CountDownLatch 的，顾名思义就是一个栅栏，其主要作用是多线程环境下，让多个线程在栅栏门口等待，所有线程到齐后，栅栏打开程序继续执行。 案例 用一个最简单的案例引出我们的主角 public class CountDownLatchDemo {public void run(CountDownLatch countDownLatch) {System.out.println(Thread.currentThread().getName() + "就位");countDownLatch.countDown();}public static void main(String[] args...
使用场景： 一个或N个线程，等待其它线程完成某项操作之后才能继续往下执行。CountDownLatch描述的是，一个或N个线程等待其他线程的关系。 使用方法： 设CountDownLatch个数：CountDownLatch countDownLatch=new CountDownLatch(3); 在等待线程中await：countDownLatch.await(); 在其他线程中减少count值：countDownLatch.getCount(); 一旦其他线程中的countDownLatch.getCount()的次数为实例化时的count值，就唤醒等待线程 ...
Word Count一、项目相关要求1.wc.exe 是一个常见的工具，它能统计文本文件的字符数、单词数和行数。这个项目要求写一个命令行程序，模仿已有wc.exe 的功能，并加以扩充，给出某程序设计语言源文件的字符数、单词数和行数。 实现一个统计程序，它能正确统计程序文件中的字符数、单词数、行数，以及还具备其他扩展功能，并能够快速地处理多个文件。2.具体功能要求：程序处理用户需求的模式为：wc.exe [parameter] [file_name] ? 3...
Github项目地址：https://github.com/softwareCQT/web_camp/tree/master/wordCount 一、题目描述实现一个简单而完整的软件工具（源程序特征统计程序）。进行单元测试、回归测试、效能测试，在实现上述程序的过程中使用相关的工具。进行个人软件过程（PSP）的实践，逐步记录自己在每个软件工程环节花费的时间。二、WC 项目要求wc.exe 是一个常见的工具，它能统计文本文件的字符数、单词数和行数。这个项目要求写一个命令行程序，模仿...
Github项目地址：https://github.com/Sabot1203/WordCount 一. 题目描述实现一个简单而完整的软件工具（源程序特征统计程序）。 进行单元测试、回归测试、效能测试，在实现上述程序的过程中使用相关的工具。 进行个人软件过程（PSP）的实践，逐步记录自己在每个软件工程环节花费的时间。二.项目要求wc.exe 是一个常见的工具，它能统计文本文件的字符数、单词数和行数。这个项目要求写一个命令行程序，模仿已有wc.exe 的功能，并加以...
Java深入学习08：CountDownLatch应用 一、CountDownLatch是什么 A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes.CountDownLatch是一个同步助手，它允许一个或多个线程在在其他线程中执行的一组操作完成前，一直处于等待状态。 二、案例 public class CountDownLatchTest {public static void main(String[] args) {CountDownLatch latch ...
闭锁示例 class count implements Runnable{private CountDownLatch cdl;count(CountDownLatch cdl){this.cdl=cdl;}@Overridepublic void run() {synchronized (this){try {for(int i=0;i<10000;i++){if(i%2==0){System.out.println(Thread.currentThread().getName()+"******"+i);}}} finally {this.cdl.countDown();}}} } public class countDownLatchTest {public static void main(String[] args) {int threadNum =5;CountDown...
Flink系列文章 java实现增量文件WordCount，任务部署到yarn我们的目标FileWindowWordCount引入依赖码代码在IDE里运行看下效果Apache Flink - 数据流上的有状态计算Apache Flink 是一个框架和分布式处理引擎，用于在无边界和有边界数据流上进行有状态的计算。Flink 能在所有常见集群环境中运行，并能以内存速度和任意规模进行计算。 接下来，我们来介绍一下 Flink 架构中的重要方面。 处理无界和有界数据 任何类型的数据都可以形成一...
原子锁是：Atomic*类的封装类型，如：AtomicInteger、AtomicLong。 CountDownLatch：是我们熟悉的栅栏，当值为0时就绪否则等待阻塞，最形象的就像赛马，发令枪不响所有马和运动员只能等。import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.atomic.AtomicInteger;/*** @ClassName: ConcurrencyTest* @Description: T...
CountDownLatch和CyclicBarrier都是控制并发而生，都在java.util.concurrent包下。 CountDownLatch 简单称为计数器，适合1个或者多个线程等待其他线程执行完毕后自己开始执行。其中最主要的方法是await和countDown，调用await()的线程如果CountDownLatch内部count变量不为0，则一直阻塞，直到为0，并且可以有多个线程调用await(),也就是多个线程同时等待。 下面的例子先创建两个线程，一直等待，然后启动10个线程对CountDownLatch进...
在13枚硬币中找出fake的那一个 输入：三次天平称量结果 1 package poj.ProblemSet;2 3 import java.util.Scanner;4 5 /*6 我怎么觉得是贪心算法呢？7 起初对所有硬币标记0；8 如果是even，则两边所有的硬币记为真(记233)；9 否则就对不确定的硬币记录怀疑(++或者--根据天平倾斜方向)； 10 最后只要看哪个硬币的绝对值最大，也就是被怀疑的次数最多，即是假币。 11 */ 12 public class poj1013 { 13 public static int[] value...