在实际的开发中我们为了提高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(); } }
可以自己实际测试一下,可以运行。自己可以查看结果即明白多线程的应用
多线程的并发执行应用(生产者消费者模式),布布扣,bubuko.com
时间: 2024-08-25 00:28:09