首页 > 代码库 > 多线程的并发执行应用(生产者消费者模式)
多线程的并发执行应用(生产者消费者模式)
在实际的开发中我们为了提高CPU的利用率,也提高程序的执行效率,我们经常使用多线程进行对数据进行并发处理,下面我举一个多线程并发执行的实例,大致意思就是
一个简单的生产者消费者模式,二个线程进行存数据,一个线程进行取数据。
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; public class BlockingQueueTest { /** * @param args */ public static void main(String[] args) { final BlockingQueue queue = new ArrayBlockingQueue(3); for (int i = 0; i < 2; i++) { new Thread(new Runnable() { @Override public void run() { while (true) { try { Thread.sleep((long) Math.random() * 1000); System.out.println(Thread.currentThread().getName() + " 准备放数据 "); queue.put(1); System.out.println(Thread.currentThread().getName() + " 队列中有数据 " + queue.size() + " 个"); } catch (InterruptedException e) { e.printStackTrace(); } } } }).start(); } new Thread(new Runnable() { @Override public void run() { while (true) { try { Thread.sleep((long) Math.random() * 1000); System.out.println(Thread.currentThread().getName() + " 准备取数据 "); queue.take(); System.out.println(Thread.currentThread().getName() + " 队列中剩余数据 " + queue.size() + " 个"); } catch (InterruptedException e) { e.printStackTrace(); } } } }).start(); } }可以自己实际测试一下,可以运行。自己可以查看结果即明白多线程的应用
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。