使用wait/notify 方法实现线程间的通信。（注意着两个方法都是object的类的方法，换句话说java为所有的对象都提供了这两个方法）
1.wait 和 notify 必须配合synchronized关键字使用。
2. wait方法释放锁，notify方法不释放锁。
package jvmtest;
import java.util.ArrayList;
import java.util.List;
public class ListAdd1 {
private volatile static List list = new ArrayList();
public void add() {
list.add("bjsxt");
}
public int size() {
return list.size();
}
public static void main(String[] args) {
final ListAdd1 list1 = new ListAdd1();
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
try {
for (int i = 0; i < 10; i++) {
list1.add();
System.out.println("当前线程:"+Thread.currentThread().getName());
Thread.sleep(500);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
},"t1");
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
while(true) {
if(list1.size() == 5) {
System.out.println("当前线程收到通知:"+Thread.currentThread().getName()+"list size = 5 线程停止..");
throw new RuntimeException();
}
}
}
},"t2");
t1.start();
t2.start();
}
}
结果如下:
当前线程:t1
当前线程:t1
当前线程:t1
当前线程:t1
当前线程:t1
当前线程收到通知:t2list size = 5 线程停止..
Exception in thread "t2" java.lang.RuntimeException
at jvmtest.ListAdd1$2.run(ListAdd1.java:44)
at java.lang.Thread.run(Thread.java:745)
当前线程:t1
当前线程:t1
当前线程:t1
当前线程:t1
当前线程:t1
线程2不断的死循环判断条件是否达成，该方式十分消耗性能，不建议采用
wait 和 notify 方式实现
package jvmtest;
import java.util.ArrayList;
import java.util.List;
/**
* wait notify 方法,wait释放锁 , notify 不释放锁
*
* @author zhouhai
*
* 2018年10月15日
*/
public class ListAdd2 {
private volatile static List list = new ArrayList();
public void add() {
list.add("bjsxt");
}
public int size() {
return list.size();
}
public static void main(String[] args) {
final ListAdd2 list2 = new ListAdd2();
// 1.实例化出来一个lock
// 当使用wait 和 notify 的时候，一定要配合
final Object lock = new Object();
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
try {
synchronized (lock) {
for (int i = 0; i < 10; i++) {
list2.add();
System.out.println("当前线程:" + Thread.currentThread().getName() + "添加了一个元素...");
Thread.sleep(500);
if (list2.size() == 5) {
System.out.println("已经发出通知..");
lock.notify();
}
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
},"t1");
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
synchronized(lock)
{
if(list2.size() != 5) {
try {
lock.wait();
} catch (Exception e) {
e.printStackTrace();
}
}
System.out.println("当前线程:"+Thread.currentThread().getName()+"收到通知线程停止...");
throw new RuntimeException();
}
}
},"t2");
t2.start();
t1.start();
}
}
结果如下：
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
已经发出通知..
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
当前线程:t2收到通知线程停止...
Exception in thread "t2" java.lang.RuntimeException
at jvmtest.ListAdd2$2.run(ListAdd2.java:72)
at java.lang.Thread.run(Thread.java:745)```
`wait/notify方式的弊端：由于notify不释放锁，线程1要执行完所有的遍历，才会释放锁，如果遍历100万次会十分消耗性能，并且会存在不实时的问题`
通过 countDownLatch类解决不实时的问题
package jvmtest;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;
/**
*
* countDownLatch类可实时通知
* @author zhouhai
*
* 2018年10月15日
*/
public class ListAdd2 {
private volatile static List list = new ArrayList();
public void add() {
list.add("bjsxt");
}
public int size() {
return list.size();
}
public static void main(String[] args) {
final ListAdd2 list2 = new ListAdd2();
//1表示一次countDown通知
final CountDownLatch countDownLatch = new CountDownLatch(1);
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
try {
for (int i = 0; i < 10; i++) {
list2.add();
System.out.println("当前线程:" + Thread.currentThread().getName() + "添加了一个元素...");
Thread.sleep(500);
if (list2.size() == 5) {
System.out.println("已经发出通知..");
countDownLatch.countDown();
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "t1");
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
if (list2.size() != 5) {
try {
countDownLatch.await();
} catch (Exception e) {
e.printStackTrace();
}
}
System.out.println("当前线程:" + Thread.currentThread().getName() + "收到通知线程停止...");
throw new RuntimeException();
}
}, "t2");
t2.start();
t1.start();
}
}
结果如下:
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
已经发出通知..
当前线程:t1添加了一个元素...
当前线程:t2收到通知线程停止...
Exception in thread "t2" java.lang.RuntimeException
at jvmtest.ListAdd2$2.run(ListAdd2.java:65)
at java.lang.Thread.run(Thread.java:745)
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
当前线程:t1添加了一个元素...
网友评论