阻塞队列的应用
之前的一篇代码说的是阻塞队列的原理实现，现在是直接使用java封装好的阻塞队列的类。比如要实现线程同步通信，子线程循环10次，再到主线程循环100次，如此循环五十次，用阻塞队列来实现代码如下：
?
package com.thread.test6;
import java.util.concurrent.ArrayBlockingQueue;
/**
?* @fileName BlockingQueueCommunication.java
?* @description 阻塞队列的应用,子线程循环10次，接着主线程循环100次，
?* 接着又回到子线程循环10次，接着再回到主线程又循环100次，
?* 如此循环50次
?* @date 2012-6-19
?* @time 21:50
?* @author wst
?*/
public class BlockingQueueCommunication {
public static void main(String[] args) {
final Business b=new Business();
//子线程
new Thread(new Runnable(){
@Override
public void run() {
for(int i=1;i<=50;i++){
b.sub(i);
}
}
}).start();
//主线程
for(int i=1;i<=50;i++){
b.main(i);
}
}
static class Business{
ArrayBlockingQueue<Integer> abq1 = new ArrayBlockingQueue<Integer>(1);
ArrayBlockingQueue<Integer> abq2 = new ArrayBlockingQueue<Integer>(1);
{
/*
* 内部匿名构造方法，总是在显性构造方法执行前执行
*/
try {
abq2.put(1);//队列2放数据
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//子线程循环10次
public void sub(int i){
try {
abq1.put(1);//队列1放
for(int j=1;j<=10;j++){
System.out.println("sub j="+j+" ?i="+i);
}
abq2.take();//队列2取，取后队列2可放，即到main执行
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//主线程循环100次
public void main(int i){
try {
abq2.put(1);//队列2放
for(int j=1;j<=100;j++){
System.out.println("main j="+j+" ?i="+i);
}
abq1.take();//队列1取，此时队列1可以放，即又到sub执行
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
?
