多线程交替打印
Jihongchang(讨论 | 贡献)2024年7月7日 (日) 02:58的版本
有两个线程,分别打印a字符和b字符
import java.util.concurrent.atomic.AtomicInteger;
public class MultiPrint2 {
public static void main(String[] args) throws InterruptedException {
Object monitor = new Object();
AtomicInteger i = new AtomicInteger(0);
PrintRunnable pr = new PrintRunnable(monitor, i, 100);
Thread t1 = new Thread(pr);
Thread t2 = new Thread(pr);
t1.start();
t2.start();
//得t1和t2都执行完才能结束
t1.join();
System.out.println(t1.getId() + "结束");
//得t1和t2都执行完才能结束
t2.join();
System.out.println(t2.getId() + "结束");
}
}
class PrintRunnable implements Runnable {
private Object monitor;
private AtomicInteger i;
private int end;
/**
* @param monitor
* @param i
* @param end
*/
public PrintRunnable(Object monitor, AtomicInteger i, int end) {
super();
this.monitor = monitor;
this.i = i;
this.end = end;
}
@Override
public void run() {
long id = Thread.currentThread().getId();
synchronized (monitor) {
while (i.get() < end) {
System.out.println(id + ":" + i.incrementAndGet());
try {
monitor.notify();
monitor.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
/**
* notify要在synchronized里,不然会抛IllegalMonitorStateException
* 这单独的一个notify调用是为了通知另一个还在while里wait的线程
*/
}
monitor.notify();
}
}
}
会有一个线程,我们假定它是A,先进入synchronized块,然后执行到wait释放锁(执行notify的时候并有其他在wait的线程,所以无所谓);
这时候另一个线程,我们叫它B,就可以进入synchronized一直执行到notify通知 wait的线程A 继续执行,之后线程B wait;
然后就是A、B两个线程交替执行,直到有一个线程,我们假定是线程A 执行完wait之后,又被线程B nofity之后 继续执行,到 while 中的判断不再成立,
于是线程A跳出while继续执行while外面的notify,然后通知在while中notify了线程A之后wait的线程B继续执行,然后线程A执行结束,线程B也在while判断不成立后跳出循环,执行notify后(因为此时并没有 wait 的线程,所以这个B线程执行的 notify 没什么影响)结束