Java多线程通信lock和wait

老付     2018-12-01   2257   6min  

在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线程结束

具体运行逻辑如下:

Java多线程通信lock和wait

总结上面的运行结果,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添加元素

(本文完)

作者:付威

如果觉得对您有帮助,可以下方的RSS订阅,或者选择右侧捐赠作者,谢谢合作

如有任何知识产权、版权问题或理论错误,还请指正。

付威的网络博客原创,自由转载-非商用-非衍生-保持署名,请遵循:创意共享3.0许可证

交流请加群113249828: 点击加群   或发我邮件 laofu_online@163.com