多线程的并发执行应用（生产者消费者模式）
浏览数：23 /
时间：2015年06月08日
在实际的开发中我们为了提高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();
}
}
可以自己实际测试一下，可以运行。自己可以查看结果即明白多线程的应用郑重声明：本站内容如果来自互联网及其他传播媒体，其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享，并不代表本站赞同其观点和对其真实性负责，也不构成任何其他建议。
