java线程池实现生产者消费者模式

本人并发小白，如果有可以优化的地方欢迎评论交流～

题目如下：

15个生产者生产1000条数据（从1开始，每生产一条加1），并向消息队列中存放字符串（“第m个生产者生产数据n”），同时3个消费者消费数据,并将数据n累加最后输出

代码如下：

生产者：

package com.lcy.thread.parta;import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.atomic.AtomicInteger;/*** 功能描述：生产者** @author liuchaoyong* @version 1.0* @date 2020/1/7 19:49*/
public class Producer implements Runnable{LinkedBlockingQueue<String> queue;private AtomicInteger data;Producer(LinkedBlockingQueue<String> queue,AtomicInteger data){this.queue=queue;this.data=data;}@Overridepublic void run() {//小于1000就一直生产while (data.get() <= Test.MAX) {String s = "第" + Thread.currentThread().getName() + "个生产者生产" + data.getAndIncrement();System.out.println(s);queue.offer(s);}}
}

消费者：

package com.lcy.thread.parta;import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.atomic.AtomicInteger;/*** 功能描述：消费者** @author liuchaoyong* @version 1.0* @date 2020/1/7 20:00*/
public class Consumer implements Runnable{private LinkedBlockingQueue<String> queue;private AtomicInteger sum;private AtomicInteger time;Consumer(LinkedBlockingQueue<String> queue,AtomicInteger time,AtomicInteger sum){this.queue=queue;this.time=time;this.sum=sum;}@Overridepublic void run() {while (time.get() != Test.MAX) {String poll = queue.poll();if (poll != null) {sum.getAndAdd(Integer.parseInt(poll.substring(poll.lastIndexOf("产") + 1)));time.getAndIncrement();}}}
}

测试类：

package com.lcy.thread.parta;import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;/*** 功能描述：** @author liuchaoyong* @version 1.0* @date 2020/1/7 20:07*/
public class Test {public static final int MAX = 1000;/***消息队列*/private static LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<>();/*** 生产者当前生产的数据*/private static AtomicInteger data = new AtomicInteger(1);/*** 累加器*/private static AtomicInteger sum = new AtomicInteger(0);/*** 消费者当前消费次数*/private static AtomicInteger time = new AtomicInteger(0);/*** 生产者线程池*/private static ThreadPoolExecutor producerExecutor;/*** 消费者线程池*/private static ThreadPoolExecutor consumerExecutor;static {producerExecutor = new ThreadPoolExecutor(15, 15, 30, TimeUnit.SECONDS, new LinkedBlockingQueue<>(), new ThreadFactory() {private AtomicInteger num = new AtomicInteger(0);@Overridepublic Thread newThread(Runnable r) {return new Thread(r, num.incrementAndGet() + "");}});consumerExecutor = new ThreadPoolExecutor(3, 3, 30, TimeUnit.SECONDS, new LinkedBlockingQueue<>(), (ThreadFactory) Thread::new);}public static void main(String[] args) {for (int i = 0; i < 15; i++) {producerExecutor.execute(new Producer(queue, data));}for (int i = 0; i < 3; i++) {consumerExecutor.execute(new Consumer(queue,time, sum));}//加到1000了就关闭生产者，并等待剩余生产者任务结束do {if (data.get() >= MAX && !producerExecutor.isShutdown()) {producerExecutor.shutdown();}} while (!producerExecutor.isTerminated());//取了1000次数据就关闭消费者，并等待消费者任务结束while (true) {if (time.get() >= MAX && !consumerExecutor.isShutdown()) {consumerExecutor.shutdown();break;}}System.out.println(sum.get());}}

java线程池实现生产者消费者模式相关推荐

Qt之线程同步（生产者消费者模式 - QSemaphore）
简述生产者将数据写入缓冲区,直到它到达缓冲区的末尾,此时,它将从开始位置重新启动,覆盖现有数据.消费者线程读取数据并将其写入标准错误. Semaphore(信号量) 比 mutex(互斥量)有 ...
Qt之线程同步（生产者消费者模式 - QWaitCondition）
简述生产者将数据写入缓冲区,直到它到达缓冲区的末尾,这时,它从开始位置重新启动,覆盖现有数据.消费者线程读取数据并将其写入标准错误. Wait condition(等待条件)比单独使用 mut ...
Java并发编程实战~生产者-消费者模式
前面我们在<Worker Thread 模式>中讲到,Worker Thread 模式类比的是工厂里车间工人的工作模式.但其实在现实世界,工厂里还有一种流水线的工作模式,类比到编程领域,就 ...
线程池原理——生产者/消费者
import java.util.ArrayList; import java.util.List; import java.util.concurrent.BlockingQueue; import ...
Java多线程（含生产者消费者模式详解）
多线程导航多线程 1 线程.进程.多线程概述 2 创建线程 (重点) 2.1 继承Thread类(Thread类也实现了Runnable接口) 2.2 实现Runnable接口(无消息返回) 2. ...
Java线程池实现多消费者批量处理队列消息
通常生产者-消费者的经典实现方式是,启动一个消费者线程从阻塞队列里获取消息进行消费,(多个)生产者往队列里插入待消费的数据然后立即返回.如果生产者生产的速率远大于消费者消费的速率,那么队列的待处理数据 ...
Java多线程：解决生产者/消费者模式
什么是生产者/消费者模式生产者消费者模型具体来讲,就是在一个系统中,存在生产者和消费者两种角色,他们通过内存缓冲区进行通信,生产者生产消费者需要的资料,消费者把资料做成产品. 具体来说就是: 生产者 ...
生产者消费者_【Java面试】实现生产者消费者模式
使用 BlockingQueue 实现生产者消费者模式 public class ProducerConsumerModel2 { private static BlockingQueue queue ...
【趣说JAVA】什么是生产者消费者模式?用恶趣味的方式来解释
故事背景: 从前有一个产奥力给怪物叫扎克,因为自己喜欢产奥力给,所以没人喜欢它,它很自卑,直到有天遇到了一个叫老八的吞翔人,两人惺惺相惜,上演了一出生产者和消费者模式的gay情故事.扎克拉完到厕所,厕 ...

java线程池实现生产者消费者模式

java线程池实现生产者消费者模式相关推荐

最新文章

热门文章