什么是线程通信、如何实现?
所谓线程通信就是线程间相互发送数据，线程通信通常通过共享一个数据的方式实现。
线程间会根据共享数据的情况决定自己该怎么做，以及通知其他线程怎么做。
线程通信常见模型
生产者与消费者模型:生产者线程负责生产数据，消费者线程负责消费数据。
要求:生产者线程生产完数据后，唤醒消费者，然后等待自己;消费者消费完该数据后，唤醒生产者，然后等待自己
|
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
public class 多线程_5线程通信 extends Thread{ public static void main(String[] args) { //定义线程类，创建一个共享的账户对象 account3 a=new account3("abc",0); //创建两个取钱的线程对象 new drawthread3(a,"小明").start(); new drawthread3(a,"小红").start(); //创建三个存钱的线程对象 new savethread(a,"存钱罐1号").start(); new savethread(a,"存钱罐2号").start(); new savethread(a,"存钱罐3号").start(); }}//存钱的线程类class savethread extends Thread{ //接收处理的账户对象 private account3 acc; public savethread(account3 acc,String name){ super(name); this.acc=acc; } public void run(){ try { while (true){ //存钱 acc.savemoney(100000); //休眠2秒 Thread.sleep(2000); } } catch (Exception e) { e.printStackTrace(); } }}//取钱的线程类class drawthread3 extends Thread{ //接收处理的账户对象 private account3 acc; public drawthread3(account3 acc,String name){ super(name); this.acc=acc; } public void run(){ try { while (true){ //取钱 acc.drawmoney3(100000); //休眠2秒 Thread.sleep(2000); } } catch (Exception e) { e.printStackTrace(); } }}class account3{ private String cartId; private double money;//账户余额 public account3() { } public account3(String cartId, double money) { this.cartId = cartId; this.money = money; } public String getCartId() { return cartId; } public void setCartId(String cartId) { this.cartId = cartId; } public double getMoney() { return money; } public void setMoney(double money) { this.money = money; } public synchronized void savemoney(double money) { //先获取是谁来存钱，线程名即是人名 String name=Thread.currentThread().getName(); //判断账户是否有钱 try { if(this.money==0){ //没钱，存钱 this.money+=money; System.out.println(name+"来存钱，存了："+money+"存钱后余额为："+this.money); //有钱了 //唤醒所有线程 this.notifyAll(); //锁对象，让当前线程进入等待 this.wait(); }else { //有钱,不存钱 //唤醒所有线程 this.notifyAll(); //锁对象，让当前线程进入等待 this.wait(); } } catch (Exception e) { e.printStackTrace(); } } public synchronized void drawmoney3(double money) { //先获取是谁来取钱，线程名即是人名 String name=Thread.currentThread().getName(); try { //判断账户是否够钱 if(this.money>=money){ //有钱，取钱 this.money-=money; System.out.println(name+"来取钱成功,取了："+money+"余额是："+this.money); //没钱了 //唤醒所有线程 this.notifyAll(); //锁对象，让当前线程进入等待 this.wait(); }else{ //余额不足 //唤醒所有线程 this.notifyAll(); //锁对象，让当前线程进入等待 this.wait(); } } catch (Exception e) { e.printStackTrace(); } }} |
以上就是Java实现线程通信的案例讲解的详细内容，更多关于Java线程通信的资料请关注服务器之家其它相关文章！
原文链接：https://blog.csdn.net/qq_62731133/article/details/124436328
