【多线程高并发】-Java使用阻塞队列ArrayBlockingQueue实现生产者消费者模式？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了【多线程高并发】-Java使用阻塞队列ArrayBlockingQueue实现生产者消费者模式？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1226字，纯文字阅读大概需要2分钟。

内容图文

在上文中的多线程高并发中，我们已经知道一个阻塞队列的三个基本功能了：

• 队列的先进先出功能；
• 队列满时，放数据会被阻塞；
• 队列空时，取数据会被阻塞；

而本次用Java实现好的ArrayBlockQueue来实现生产者-消费者模式。

• 生产者往队列里面放东西；
• 消费者从队列里面取东西；

package com.lcz.tencent.thread;

import java.util.concurrent.ArrayBlockingQueue;

// 阻塞队列实现多线程下的生产者和消费者模式
public class ArrayBlockQueueDemo {
	static ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<>(1);
	// 主函数
	public static void main(String[] args) {
		// 生产者
		for(int i=0;i<3;i++) {
			new Thread(()->producer(),"producerThread" + i).start();
		}
		// 消费者
		for(int i=0;i<3;i++) {
			new Thread(()->consumer(),"consumerThread" + i).start();
		}
	}
	// 生产者
	public static void producer() {
		for(int i=0;i<100;i++) {
			try {
				queue.put("[" + i + "]");
				System.out.println(Thread.currentThread().getName() + "->send msg" + i);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
		
	}
	// 消费者
	public static void consumer() {
		// 队列只要有数据就往走
		while(true) {
			try {
				String msg = queue.take();
				System.out.println(Thread.currentThread().getName()+"->receive msg:" + msg);
			}catch (InterruptedException e) {
				// TODO: handle exception
				e.printStackTrace();
			}
		}
	}
	
}

内容总结

以上是互联网集市为您收集整理的【多线程高并发】-Java使用阻塞队列ArrayBlockingQueue实现生产者消费者模式？全部内容，希望文章能够帮你解决【多线程高并发】-Java使用阻塞队列ArrayBlockingQueue实现生产者消费者模式？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端