BlockingQueue 队列模拟生产者消费者问题
多线程环境中，经过队列能够很容易实现数据共享，好比经典的“生产者”和“消费者”模型中，经过队列能够很便利地实现二者之间的数据共享（生产者线程向队列中放数据，消费者线程从队列中取线程消费）。java
首页 咱们得有一个消费的模型，至少咱们得知道生产什么，消费什么吧。多线程
class product {
private String productID;
private String productName;
public String getProductID() {
return productID;
}
public void setProductID(String productID) {
this.productID = productID;
}
public String getProductName() {
return productName;
}
public void setProductName(String productName) {
this.productName = productName;
}
public product(String productID, String productName) {
super();
this.productID = productID;
this.productName = productName;
}
public product() {
super();
}
}
而后要有一个生产者线程，消费者线程dom
生产者线程往一个队列里面放数据（product）,消费者线程从队列里取数据(product) 因此 咱们须要一个 队列 来做为一个容器。this
BlockingQueue<product> productQueue = new LinkedBlockingQueue<product>(20);
生产者线程spa
这里的put方法在队列满的状况下线程会阻塞线程
class produceThread implements Runnable{
public produceThread(BlockingQueue<product> productQueue) {
// TODO Auto-generated constructor stub
this.productQueue = productQueue;
}
public static String randSix(){
String []baseStr = {"1","2","3","4","5","6","7","8","9","0",
"a","b","c","d","e","A","B"};
String str="";
for(int i = 0 ;i<6;i++){
int index = ((int)(100*Math.random()))%baseStr.length;
str += baseStr[index];
}
return str;
}
BlockingQueue<product> productQueue;
public void run() {
// TODO Auto-generated method stub
product p = new product(randSix(),Thread.currentThread().getName()+"线程生产");
try {
productQueue.put(p);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"线程生产了一个产品,产品ID "+p.getProductID());
}
}
消费者线程code
take方法在 队列里面没数据的时候会阻塞队列
class consumeThread implements Runnable{
BlockingQueue<product> productQueue;
public consumeThread(BlockingQueue<product> productQueue) {
// TODO Auto-generated constructor stub
this.productQueue = productQueue;
}
public void run() {//把这个 product从队列里取出来
// TODO Auto-generated method stub
try {
product p = productQueue.take();
System.out.println("消费线程:"+Thread.currentThread().getName()+"线程消费了一个产品,产品ID "+p.getProductID());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
整个代码get
ScheduledExecutorService service = Executors.newScheduledThreadPool(3); 产品
这行代码构造了一个线程池 执行定时任务 这个线程池里有3个线程
package com.dlh.concurrent;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.TimeUnit;
public class blockingQueueService{
public static void main(String[] args) {
// TODO Auto-generated method stub
@SuppressWarnings("unused")
BlockingQueue<product> productQueue = new LinkedBlockingQueue<product>(20);
//每隔1秒定时执行
ScheduledExecutorService service = Executors.newScheduledThreadPool(3);
service.scheduleAtFixedRate(new produceThread(productQueue), 1, 1,TimeUnit.SECONDS);
//每隔2秒定时执行
ScheduledExecutorService service1 = Executors.newScheduledThreadPool(3);
service1.scheduleAtFixedRate(new produceThread(productQueue), 1, 2,TimeUnit.SECONDS);
//每隔3秒定时执行
ScheduledExecutorService service2 = Executors.newScheduledThreadPool(3);
service2.scheduleAtFixedRate(new produceThread(productQueue), 1, 3,TimeUnit.SECONDS);
//每隔4秒定时执行
ScheduledExecutorService service3 = Executors.newScheduledThreadPool(3);
service3.scheduleAtFixedRate(new consumeThread(productQueue), 1, 4,TimeUnit.SECONDS);
}
}
class produceThread implements Runnable{
public produceThread(BlockingQueue<product> productQueue) {
// TODO Auto-generated constructor stub
this.productQueue = productQueue;
}
public static String randSix(){
String []baseStr = {"1","2","3","4","5","6","7","8","9","0",
"a","b","c","d","e","A","B"};
String str="";
for(int i = 0 ;i<6;i++){
int index = ((int)(100*Math.random()))%baseStr.length;
str += baseStr[index];
}
return str;
}
BlockingQueue<product> productQueue;
public void run() {
// TODO Auto-generated method stub
product p = new product(randSix(),Thread.currentThread().getName()+"线程生产");
try {
productQueue.put(p);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"线程生产了一个产品,产品ID "+p.getProductID());
}
}
class consumeThread implements Runnable{
BlockingQueue<product> productQueue;
public consumeThread(BlockingQueue<product> productQueue) {
// TODO Auto-generated constructor stub
this.productQueue = productQueue;
}
public void run() {//把这个 product从队列里取出来 要不要考虑 对这个product处理的结果 好比处理成功再 从take取一个product
// TODO Auto-generated method stub
try {
product p = productQueue.take();
System.out.println("消费线程:"+Thread.currentThread().getName()+"线程消费了一个产品,产品ID "+p.getProductID());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
class product {
private String productID;
private String productName;
public String getProductID() {
return productID;
}
public void setProductID(String productID) {
this.productID = productID;
}
public String getProductName() {
return productName;
}
public void setProductName(String productName) {
this.productName = productName;
}
public product(String productID, String productName) {
super();
this.productID = productID;
this.productName = productName;
}
public product() {
super();
}
}
下面咱们运行下代码
pool-2-thread-1线程生产了一个产品,产品ID 41184a pool-1-thread-1线程生产了一个产品,产品ID a84d56 消费线程:pool-4-thread-1线程消费了一个产品,产品ID 41184a pool-3-thread-1线程生产了一个产品,产品ID 0113A7 pool-1-thread-1线程生产了一个产品,产品ID A619a5 ----------pool-1 的第一个线程 pool-1-thread-2线程生产了一个产品,产品ID 11eAe9 pool-2-thread-1线程生产了一个产品,产品ID 5bb9a2 pool-1-thread-2线程生产了一个产品,产品ID Bec28A ----------pool-1 的第二个线程 pool-3-thread-1线程生产了一个产品,产品ID B5a017 pool-1-thread-2线程生产了一个产品,产品ID c8A0d8 pool-2-thread-2线程生产了一个产品,产品ID 91Ad21 消费线程:pool-4-thread-1线程消费了一个产品,产品ID a84d56 pool-1-thread-2线程生产了一个产品,产品ID b07A53 pool-1-thread-2线程生产了一个产品,产品ID 974c25 pool-2-thread-1线程生产了一个产品,产品ID 6B36bB pool-3-thread-2线程生产了一个产品,产品ID 70d49b pool-1-thread-1线程生产了一个产品,产品ID b67cbe pool-2-thread-3线程生产了一个产品,产品ID 223261 消费线程:pool-4-thread-2线程消费了一个产品,产品ID 0113A7 pool-1-thread-1线程生产了一个产品,产品ID cad53e pool-3-thread-1线程生产了一个产品,产品ID b30e6B pool-1-thread-1线程生产了一个产品,产品ID ed6a76 pool-1-thread-1线程生产了一个产品,产品ID 702c31 pool-2-thread-3线程生产了一个产品,产品ID 1757b1 pool-1-thread-1线程生产了一个产品,产品ID Ab22c2 pool-1-thread-3线程生产了一个产品,产品ID a3a567 ----------pool-1 的第三个线程 消费线程:pool-4-thread-1线程消费了一个产品,产品ID A619a5 pool-2-thread-3线程生产了一个产品,产品ID cBd508
相关文章
- 1. 使用阻塞队列解决生产者-消费者问题
- 2. Java阻塞队列(BlockingQueue)实现 生产者/消费者 示例
- 3. 生产者与消费者（三）---BlockingQueue
- 4. Java 生产者消费者实现——BlockingQueue
- 5. 生产者消费者问题总结
- 6. java阻塞队列实现生产者消费者模式
- 7. 生产者/消费者模式(阻塞队列)
- 8. 生产者消费者问题
- 9. 用BlockingQueue实现生产者消费者问题
- 10. 阻塞队列和生产者-消费者模式、DelayQueue
- 更多相关文章...
- • C# 队列（Queue） - C#教程
- • 免费ARP详解 - TCP/IP教程
- • 适用于PHP初学者的学习线路和建议
- • 委托模式
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. eclipse设置粘贴字符串自动转义
- 2. android客户端学习-启动模拟器异常Emulator: failed to initialize HAX: Invalid argument
- 3. android.view.InflateException: class com.jpardogo.listbuddies.lib.views.ListBuddiesLayout问题
- 4. MYSQL8.0数据库恢复 MYSQL8.0ibd数据恢复 MYSQL8.0恢复数据库
- 5. 你本是一个肉体，是什么驱使你前行【1】
- 6. 2018.04.30
- 7. 2018.04.30
- 8. 你本是一个肉体，是什么驱使你前行【3】
- 9. 你本是一个肉体，是什么驱使你前行【2】
- 10. 【资讯】LocalBitcoins达到每周交易比特币的7年低点
欢迎关注本站公众号,获取更多信息
