个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
33
4
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章Java基于Lock的生产者消费者模型示例由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.
本文实例讲述了java基于lock的生产者消费者模型。分享给大家供大家参考，具体如下:
前面一篇《java锁机制lock用法》简单介绍了锁机制，这里进一步分析一下基于lock的生产者消费者模型.
|
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
|
package
com.expgiga.juc;
import
java.util.concurrent.locks.condition;
import
java.util.concurrent.locks.lock;
import
java.util.concurrent.locks.reentrantlock;
/**
* 生产者消费者案例
*/
public
class
testproductorandconsumerforlock {
public
static
void
main(string[] args) {
clerk clerk =
new
clerk();
productor productor =
new
productor(clerk);
consumer consumer =
new
consumer(clerk);
new
thread(productor,
"生产者a"
).start();
new
thread(consumer,
"消费者b"
).start();
new
thread(productor,
"生产者c"
).start();
new
thread(consumer,
"消费者d"
).start();
}
}
//店员
class
clerk {
private
int
product =
0
;
private
lock lock =
new
reentrantlock();
private
condition condition = lock.newcondition();
//进货方法
public
void
get() {
lock.lock();
try
{
while
(product >=
1
) {
//为了避免虚假唤醒，应该总是使用在循环中
system.out.println(
"产品已满！"
);
try
{
condition.await();
}
catch
(interruptedexception e) {
e.printstacktrace();
}
}
system.out.println(thread.currentthread().getname() +
" : "
+ ++product);
condition.signalall();
}
finally
{
lock.unlock();
}
}
//卖货方法
public
void
sale() {
lock.lock();
try
{
while
(product <=
0
) {
system.out.println(
"产品缺货！"
);
try
{
condition.await();
}
catch
(interruptedexception e) {
e.printstacktrace();
}
}
system.out.println(thread.currentthread().getname() +
" : "
+ --product);
condition.signalall();
}
finally
{
lock.unlock();
}
}
}
//生产者
class
productor
implements
runnable {
private
clerk clerk;
public
productor(clerk clerk) {
this
.clerk = clerk;
}
@override
public
void
run() {
for
(
int
i =
0
; i <
20
; i++) {
try
{
thread.sleep(
200
);
}
catch
(interruptedexception e) {
e.printstacktrace();
}
clerk.get();
}
}
}
//消费者
class
consumer
implements
runnable {
private
clerk clerk;
public
consumer(clerk clerk) {
this
.clerk = clerk;
}
@override
public
void
run() {
for
(
int
i =
0
; i <
20
; i++) {
clerk.sale();
}
}
}
|
运行结果:
产品缺货！ 产品缺货！ 生产者a : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者c : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者a : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者c : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者a : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者c : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者a : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者c : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者a : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者c : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者a : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者c : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者a : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者c : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者a : 1 产品已满！ 消费者b : 0 产品缺货！ 产品缺货！ 生产者c : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者c : 1 产品已满！ 消费者b : 0 产品缺货！ 产品缺货！ 生产者a : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者c : 1 消费者b : 0 产品缺货！ 产品缺货！ 生产者a : 1 消费者b : 0 产品缺货！ 生产者c : 1 消费者d : 0 产品缺货！ 生产者a : 1 消费者d : 0 产品缺货！ 生产者c : 1 消费者d : 0 产品缺货！ 生产者a : 1 消费者d : 0 产品缺货！ 生产者c : 1 消费者d : 0 产品缺货！ 生产者a : 1 消费者d : 0 产品缺货！ 生产者c : 1 消费者d : 0 产品缺货！ 生产者a : 1 消费者d : 0 产品缺货！ 生产者c : 1 消费者d : 0 产品缺货！ 生产者a : 1 消费者d : 0 产品缺货！ 生产者c : 1 消费者d : 0 产品缺货！ 生产者a : 1 消费者d : 0 产品缺货！ 生产者c : 1 消费者d : 0 产品缺货！ 生产者a : 1 消费者d : 0 产品缺货！ 生产者c : 1 消费者d : 0 产品缺货！ 生产者a : 1 消费者d : 0 产品缺货！ 生产者c : 1 消费者d : 0 产品缺货！ 生产者a : 1 消费者d : 0 产品缺货！ 生产者c : 1 消费者d : 0 产品缺货！ 生产者a : 1 消费者d : 0 。
希望本文所述对大家java程序设计有所帮助.
原文链接：https://blog.csdn.net/u013063153/article/details/76407240 。
最后此篇关于Java基于Lock的生产者消费者模型示例的文章就讲到这里了,如果你想了解更多关于Java基于Lock的生产者消费者模型示例的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
33
4
0
我想知道锁是如何在 Java 中实现的。在一些教程中，我发现它们应该使用 wait() 和 notify()/notifyAll() 以及一些 boolean 标志来实现(它可能比那复杂得多，但基本上
我正在开发一个多线程服务器，用于存储和读取来自数据库的信息。数据库是用 RocksDB 实现的。 我遇到的问题是，当我一次从多个线程访问数据库时，我得到了那个错误。 通常是说db在usign后没有被删
例如，这里有一些 linux 中的代码: void set_leds(int val) { int fd = open ("/dev/console", O_WRONLY); // argumen
关闭。这个问题需要更多focused .它目前不接受答案。 想改进这个问题吗？ 更新问题，使其只关注一个问题 editing this post . 关闭 9 年前。 Improve this qu
考虑以下代码。为了防止IndexOutOfBoundsException打电话时 listIterator ，我们使用读取器锁来检索基于索引的 iteartor，并在对 stockCodes 进行写操
这个问题在这里已经有了答案: Java locking structure best pattern (2 个答案) 关闭 6 年前。 有什么区别: private Lock lock = new
是否可以在网页加载时检查 Scroll Lock、Num Lock 和 Caps Lock 的状态？我找到了使用 JavaScript 在按键后进行检查的方法，但这不是我要问的。 最佳答案 2019
是否可以在网页加载时检查 Scroll Lock、Num Lock 和 Caps Lock 的状态？我找到了使用 JavaScript 在按键后进行检查的方法，但这不是我要问的。 最佳答案 2019
在Ubuntu中安装某些东西时出现错误。我尝试了一些命令来杀死正在运行的进程，但仍然遇到相同的错误。 最佳答案 根据文章How to Fix “Waiting for cache lock: Coul
我们有一个gradle构建，它可以动态创建GradleBuild类型的多个任务，以与不同的客户端库版本一起运行以测试其兼容性。在Gradle4上可以正常工作，但是在移至Gradle5后，执行第一项任务
我在尝试运行在 vertica 数据库表上运行查询的客户端应用程序时反复遇到此错误。 有人可以帮助解决这个问题吗？ 最佳答案 我想知道您的客户端应用程序向 Vertica 发送了哪种“查询”(以 RE
我有一个创建锁的方法。 ReadWriteLock lock = new ReentrantReadWriteLock(); 然后我使用 Lock Interface 将该对象传递到一个方法中。 m
正如问题所问，我知道这是可能的on Linux ，但我找不到任何适用于 Windows 的最新信息。有可能吗？ 最佳答案 您可以使用 ctypes 加载 user32.dll 然后调用 GetKeyS
这是同一个问题 Change keyboard locks in Python或者 How to change caps lock status without key press . 但还是有区别的
与 this question 相同，不知道为什么Java团队没有在Lock中添加一些默认方法界面，类似这样: public default void withLock(Runnable r) {
我有一个带有package-lock.json文件的项目。 现在，我想基于yarn.lock文件或项目的现有package-lock.json生成node_modules文件。 我怎样才能做到这一点？
我正在查看 pthreadtypes.h 文件中的 pthread_mutex_t 结构。 “__lock”代表什么？它就像分配给互斥锁的锁号吗？ typedef union { struct _
我正在研究避免死锁的措施，其中一种可能的方法是通过强制线程放弃它在访问另一个锁但无法访问该锁时已经持有的锁来打破循环等待。 以最简单的银行账户转账为例: class Account { priva
我被要求支持一些遗留代码，我看到了一些让我摸不着头脑的事情。在某些代码段中，我看到类实例使用 CMutex 实例来同步方法执行。例如 class CClassA : public CObject {
当我们调用 lock.lock() 或尝试进入一个 synchronized block 时，如果其他线程已经获取了该锁，我们的线程就会阻塞。现在我的问题是，当我们查看 lock.lock() 的实现
我是一名优秀的程序员,十分优秀！