Java多线程通信lock和wait

在Java多线程中有一对配合使用过的两个方法，来实现线程间通信的功能–lock和wait, 由于这个需要获得锁，所以必须结合synchronized一起使用。首先我们先看一个例子：

public class LockWait {
	
	static volatile List<String> itemContainer = new ArrayList<>();
	static Object obj = new Object();
	
	public static void main(String[] args) {
Thread th1 = new Thread(() -> {
	synchronized (obj) {
		for (int i = 0; i < 10; i++) {
			System.out.println("th1添加元素");
			itemContainer.add(String.valueOf(i));
			if (itemContainer.size() == 5) {
				System.out.println("th1线程发出通知");
				obj.notify();
			}
		}
	}
});

Thread th2 = new Thread(() -> {
	synchronized (obj) {
		System.out.println("进入th2线程");
		if (itemContainer.size() != 5) {
			try {
				System.out.println("th2线程开始等待");
				obj.wait();
				System.out.println("th2线程等待结束");
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
			System.out.println("th2线程结束");
		}
	}
	
});

th2.start();
th1.start();
	}
}
 

输出结果如下：

进入th2线程
th2线程开始等待
th1添加元素
th1添加元素
th1添加元素
th1添加元素
th1添加元素
th1线程发出通知
th1添加元素
th1添加元素
th1添加元素
th1添加元素
th1添加元素
th2线程等待结束
th2线程结束

具体运行逻辑如下：

总结上面的运行结果，th2在wait的时候，th1可以持有锁。说明wait是释放锁，而notify不释放锁。

这样也就带来了一个弊端，无法实时的得到结果，就是说当List达到我们想要的结果的时候，th1线程一直还在持有锁，导致th2无法执行。

有没有更好办法呢？在Java中提供了一个CountDownLatch类：

public class CountDownLatchTest {
	
	public static void main(String[] args) {
final List<String> itemContainer = new ArrayList<>();
final CountDownLatch countDownLanch = new CountDownLatch(1);
Thread th1 = new Thread(() -> {
	for (int i = 0; i < 10; i++) {
		try {
			System.out.println("th1添加元素");
			itemContainer.add(String.valueOf(i));
			if (itemContainer.size() == 5) {
				System.out.println("th1线程发出通知");
				countDownLanch.countDown();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		
	}
});

Thread th2 = new Thread(() -> {
	System.out.println("进入th2线程");
	if (itemContainer.size() != 5) {
		try {
			System.out.println("th2线程开始等待");
			countDownLanch.await();
			System.out.println("th2线程等待结束");
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println("th2线程结束");
	}
	
});

th2.start();

th1.start();
	}
}

运行结果：

进入th2线程
th1添加元素
th2线程开始等待
th1添加元素
th1添加元素
th1添加元素
th1添加元素
th1线程发出通知
th1添加元素
th2线程等待结束
th1添加元素
th2线程结束
th1添加元素
th1添加元素
th1添加元素