Java多线程实战之交叉打印的两种方法

2019-11-26 09:16:53

字体：大中小

来源：转载

供稿：网友

要求效果：先打印5次“printA…”，再打印5次“printB…”，每次打印间隔1秒，重复循环20次

方式一：使用wait()和notifyAll()方法

public class MyService { private volatile boolean flag = false; public synchronized void printA() { try {  while (flag) {  wait();  }  for (int i = 0; i < 5; i++) {  System.out.println("printA...");  TimeUnit.SECONDS.sleep(1);  }  flag = true;  notifyAll(); } catch (InterruptedException e) {  e.printStackTrace(); } } public synchronized void printB() { try {  while (!flag) {  wait();  }  for (int i = 0; i < 5; i++) {  System.out.println("printB...");  TimeUnit.SECONDS.sleep(1);  }  flag = false;  notifyAll(); } catch (InterruptedException e) {  e.printStackTrace(); } }}

public class BackupA implements Runnable { private MyService myService; public BackupA(MyService myService) { super(); this.myService = myService; } @Override public void run() { myService.printA(); }}

public class BackupB implements Runnable { private MyService myService; public BackupB(MyService myService) { super(); this.myService = myService; } @Override public void run() { myService.printB(); }}

public class Run { public static void main(String[] args) { MyService myService = new MyService(); for (int i = 0; i < 20; i++) {  new Thread(new BackupA(myService)).start();  new Thread(new BackupB(myService)).start(); } }}

方式二：使用await()和signalAll()方法

public class MyService { private Lock lock = new ReentrantLock(); private Condition condition = lock.newCondition(); private boolean flag = false; public void printA() { try {  lock.lock();  while (flag) {  condition.await();  }  for (int i = 0; i < 5; i++) {  System.out.println("printA...");  TimeUnit.SECONDS.sleep(1);  }  flag = true;  condition.signalAll(); } catch (InterruptedException e) {  e.printStackTrace(); } finally {  lock.unlock(); } } public void printB() { try {  lock.lock();  while (!flag) {  condition.await();  }  for (int i = 0; i < 5; i++) {  System.out.println("printB...");  TimeUnit.SECONDS.sleep(1);  }  flag = false;  condition.signalAll(); } catch (InterruptedException e) {  e.printStackTrace(); } finally {  lock.unlock(); } }}

public class ThreadA implements Runnable { private MyService myService; public ThreadA(MyService myService) { super(); this.myService = myService; } @Override public void run() { myService.printA(); }}

public class ThreadB implements Runnable { private MyService myService; public ThreadB(MyService myService) { super(); this.myService = myService; } @Override public void run() { myService.printB(); }}

public class Run { public static void main(String[] args) { MyService myService = new MyService(); for (int i = 0; i < 20; i++) {  new Thread(new ThreadA(myService)).start();  new Thread(new ThreadB(myService)).start(); } }}

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对武林网的支持。如果你想了解更多相关内容请查看下面相关链接

上一篇：优雅地在Java应用中实现全局枚举处理的方法

下一篇：Java多线程实战之单例模式与多线程的实例详解