两线程间通信

2019-11-06 09:22:05

字体：大中小

来源：转载

供稿：网友

创建两个线程类

package Thread01;public class T1 extends Thread{ PRinter p; public T1(Printer p){ this.p=p; } public void run(){ while(true){ try { p.printA(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }}package Thread01;public class T2 extends Thread { Printer p; public T2(Printer p){ this.p=p; } public void run(){ while(true){ try { p.printB(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }}

假如现在要实现一个功能，打印一次aaa,再打印一次bbbbbb,再打印一次aaa,再打印一次bbbbbb。。。。。。

package Thread01;public class Printer { int flag = 1;//加标志位 public void printA() throws InterruptedException { synchronized (this) { if (flag != 1) {//判断标志位，假如满足，则该线程等待 this.wait(); } System.out.print("a"); System.out.print("a"); System.out.print("a"); System.out.println(); flag = 2; // 修改标记 this.notify();// 唤醒另外一条线程 } } public void printB() throws InterruptedException { synchronized (this) { if (flag != 2) { this.wait(); } System.out.print("b"); System.out.print("b"); System.out.print("b"); System.out.print("b"); System.out.print("b"); System.out.print("b"); System.out.println(); flag = 1; this.notify(); } }}package Thread01;public class Demo01 { public static void main(String[] args) { Printer printer = new Printer(); T1 t1=new T1(printer); T2 t2=new T2(printer); t1.start(); t2.start(); }}

解析：上面开启了两个线程t1,t2，它们谁先运行是随机的。假如现在t2先运行，调用PrintB函数，进入同步代码块（在同步代码块里面，其他线程不能强占运行，直到该线程的同步代码块运行完），由于flag此时等于1，所以1！=2 if条件为真，该线程处于等待状态，不再向下运行。并且该线程释放对象锁（注意wait()与sleep()的区别,wait()释放对象锁，sleep()不释放对象锁），然后线程t1获取对象锁(注意同步代码块的对象锁必须是同一把锁，即同一个对象)，进入同步代码块，由于flag=1所以1！=1为假，if条件不满足。开始打印aaa,然后修改标志位，flag=2;再执行notify()方法。该方法会唤醒另一个线程,即t2,此时t1的同步代码块执行完，释放对象锁，此时t2被唤醒，立刻获得对象锁，又锁上了同步代码块，（注意在哪等待，唤醒后就从哪开始执行，所以此时t2不用再判断，直接运行了，因为是if判断，假如是while则需要继续判断，）打印bbbbbb，然后改变标志位flag=1,执行notify()方法，唤醒线程t1(尽管线程t1没有等待，也唤醒它一次，不影响)。释放对象锁。然后线程t1和t2又开始强占资源了。。。。注意： 1、sleep()与wait()的区别 sleep()指定时间过后，自己醒。不释放锁。 wait()必须让别人叫醒，释放锁。 2、用哪个对象锁，就用哪个wait(),notiyfy()。 3、开启线程使用start()，不是run()。 4、wait()是使当前线程等待，notify()是叫醒其他线程

上一篇：svm损失和交叉熵损失

下一篇：AS3移动设备上的触控事件和手势