实际应用java多线程 java 多线程应用
2023-06-09
情景1
如果有Thread11、Thread2、ThreaD3、四条线程各自统计CThread4。、D、E、四盘大小，全过程统计完毕，交给Thread5进程进行汇总，该如何实现？
第一，通过java.util.concurrent.在Executors中创建一个线程池，并使用这个线程池来启动这个过程。启动所有要启动的过程后，执行线程池的shutdown()方法，即在所有过程完成后关闭线程池。然后通过isTerminated()线程池的方法来判断线程池是否已关闭。成功关闭线程池，意味着整个过程已经完成。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Test {
public static void main(String args[]) throws InterruptedException {
ExecutorService exe = Executors.newFixedThreadPool(50);
for (int i = 1; i <= 5; i ) {
exe.execute(new SubThread(i));
}
exe.shutdown();
while (true) {
if (exe.isTerminated()) {
System.out.println(“结束了！");
break;
}
Thread.sleep(200);
}
}
}
View Code
2）使用T.join，让主线程等待这些工作线程结束。
public class 011JoinTester implements Runnable {
private String name;
public 011JoinTester(String name) {
this.name = name;
}
public void run() {
System.out.printf("%s begins: %s\n", name, new Date());
try {
TimeUnit.SECONDS.sleep(4);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.printf("%s has finished: %s\n", name, new Date());
}
public static void main(String[] args) {
while (true){
Thread thread1 = new Thread(new “JoinTester01”One"));
Thread thread2 = new Thread(new “JoinTester01”Two"));
thread1.start();
thread2.start();
try {
thread1.join();
thread2.join();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("Main thread is finished");
}
}
}
View Code
情景2
实现经典消费模式
1 package com.example.demo.consumer;
2
3 import java.util.LinkedList;
4
5 /**
6 * 生产者和消费者之间的问题
7 * wait、notify/notifyAll() 实现
8 */
9 public class Storage1 implements AbstractStorage {
10 //仓库最大容量
11 private static final int _1MB = 128;
12 private final int MAX_SIZE = 100;
13 //仓库存储载体
14 private LinkedList list = new LinkedList();
15 //private Object object = new Object();
16 //进行生产
17 public void produce(int num){
18 //同步
19 synchronized (list){
20 //仓库剩余容量不足以储存即将生产的总产量，暂停生产
21 while(list.size() num > MAX_SIZE){
22 System.out.println("""要生产的产品数量":" num "\t【库存量】:"
23 list.size() "\t暂时无法完成生产任务！");
24
25 try {
26 //不符合条件，生产堵塞
27 list.wait();
28 } catch (InterruptedException e) {
29 e.printStackTrace();
30 }
31 }
32
33 for(int i=0;i list.size()){
50 System.out.println(“要消费的产品数量”:" num "\t【库存量】:"
51 list.size() "\t暂时无法完成消费任务！");
52
53 try {
54 list.wait();
55 } catch (InterruptedException e) {
56 e.printStackTrace();
57 }
58 }
59 //满足消费条件，开始消费
60 for(int i=0;i
Storage1
public class Test{
public static void main(String[] args) {
// 仓库目标
AbstractStorage abstractStorage = new ()Storage1();
// 生产者目标
Producer p1 = new Producer(abstractStorage);
Producer p2 = new Producer(abstractStorage);
Producer p3 = new Producer(abstractStorage);
Producer p4 = new Producer(abstractStorage);
Producer p5 = new Producer(abstractStorage);
Producer p6 = new Producer(abstractStorage);
Producer p7 = new Producer(abstractStorage);
// 顾客目标
Consumer c1 = new Consumer(abstractStorage);
Consumer c2 = new Consumer(abstractStorage);
Consumer c3 = new Consumer(abstractStorage);
// 设定生产者产品制造数量。
p1.setNum(10);
p2.setNum(10);
p3.setNum(10);
p4.setNum(10);
p5.setNum(10);
p6.setNum(10);
p7.setNum(80);
// 设定客户消费商品的数量
c1.setNum(50);
c2.setNum(20);
c3.setNum(30);
// 进程开始实施
c1.start();
// try {
// Thread.sleep(1000);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// abstractStorage.test();
c2.start();
c3.start();
p1.start();
p2.start();
p3.start();
p4.start();
p5.start();
p6.start();
p7.start();
}
}
main function
to be continued
本文为转载内容，我们尊重原作者对本文的作权。如有内容错误或侵权问题，欢迎原作者联系我们更正或删除内容。
本文仅代表作者观点，版权归原创者所有，如需转载请在文中注明来源及作者名字。
免责声明：本文系转载编辑文章，仅作分享之用。如分享内容、图片侵犯到您的版权或非授权发布，请及时与我们联系进行审核处理或删除，您可以发送材料至邮箱：service@tojoy.com