要求效果：先打印5次[printa…]，再打印5次[printb…]，每次打印间隔1秒，重复循环20次
方式一：使用wait()和notifyall()方法
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 |
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(); } } } |
|
1 2 3 4 5 6 7 8 9 10 11 |
public class backupa implements runnable { private myservice myservice; public backupa(myservice myservice) { super (); this .myservice = myservice; } @override public void run() { myservice.printa(); } } |
|
1 2 3 4 5 6 7 8 9 10 11 |
public class backupb implements runnable { private myservice myservice; public backupb(myservice myservice) { super (); this .myservice = myservice; } @override public void run() { myservice.printb(); } } |
|
1 2 3 4 5 6 7 8 9 |
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()方法
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 |
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(); } } } |
|
1 2 3 4 5 6 7 8 9 10 11 |
public class threada implements runnable { private myservice myservice; public threada(myservice myservice) { super (); this .myservice = myservice; } @override public void run() { myservice.printa(); } } |
|
1 2 3 4 5 6 7 8 9 10 11 |
public class threadb implements runnable { private myservice myservice; public threadb(myservice myservice) { super (); this .myservice = myservice; } @override public void run() { myservice.printb(); } } |
|
1 2 3 4 5 6 7 8 9 |
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(); } } } |
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对的支持。如果你想了解更多相关内容请查看下面相关链接
原文链接：https://blog.csdn.net/qq_40378034/article/details/86766001
查看更多关于Java多线程实战之交叉打印的两种方法的详细内容...