CountDownLatch(ロック)を簡単に使用

1.CountTestクラスはCallableインタフェースを実現し、同時に1つの数値を増加するために使用する。

public class CountTest implements Callable<Integer>{
	private CountDownLatch adl;
	
	public CountTest(CountDownLatch adl) {
		this.adl = adl;
	}
	@Override
	public Integer call() throws Exception {
		adl.await();
		/*   */
		/*int i ;
		synchronized (CountDownLatchTest.class) {
			i = CountDownLatchTest.count++;
		}
		return i;*/
		return CountDownLatchTest.count++;
	}
}

2.CountDownLatchTest

public class CountDownLatchTest {
	static int count=0;
	
	public static void main(String[] args) throws InterruptedException {
		CountDownLatch adl = new CountDownLatch(1000);
		
		ExecutorService es = Executors.newFixedThreadPool(1000);
		for(int i =0;i<1000;i++){
			es.submit(new CountTest(adl));
			adl.countDown();
		}
		Thread.sleep(200);
		System.out.println("first==>+"count);
		Thread.sleep(200);
		System.out.println("second==>+"count);
		es.shutdown();
		System.out.println("third==>"+count);
	}
	
}

このクラスには1000個のCountTestオブジェクトがインスタンス化され、すべてのスレッドがadlにコミット.最後のスレッドがsubmit(adl.contDown()によって閉鎖条件が達成されるまでawait()で待機すると、すべてのスレッドが同時に自己増加動作を開始します.

3.運転結果

実行結果は、ハードウェア・デバイスによって異なり、実行するたびに異なる結果が発生する可能性があります.javaでの自己増加(i++)操作時の非原子性も間接的に証明されています.次は、印刷結果が予想と一致しない例を1回だけ貼り付けます.

first==>999
second==>999
third==>999

連続印刷はcountの結果がすべてのスレッドタスクが完了した最終結果であることを保証するために行われます.