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

时间:2022-09-28 19:04:18

要求效果:先打印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