线程A：1 线程A：2 线程A：3 线程B：4 线程B：5 线程B：6 线程A：7 线程A：8 线程A：9 ...（直到显示30）
3个一组输出30个数
public class TestSange {
public static void main(String[] args) {
final BlockingQueue queue = new ArrayBlockingQueue(30);
final Semaphore sp = new Semaphore(1);
final Lock lock = new ReentrantLock();
final Condition a = lock.newCondition();
final Condition b = lock.newCondition();
int targ=0;
for (int i = 1; i <= 30; i++) {
try {
queue.put(i);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
new Thread(new Runnable() {
@Override
public void run() {
lock.lock();
boolean flag=false;
while(true){
if(flag){
try {
a.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
flag=false;
}
for(int i=0;i<3;i++){
try {
System.out.println("线程A"+queue.take());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
b.signal();
flag=true;
}
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
lock.lock();
boolean flag=false;
while(true){
if(flag){
try {
b.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
flag=false;
}
for(int i=0;i<3;i++){
try {
System.out.println("线程B"+queue.take());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
a.signal();
flag=true;
}
}
}).start();
}
}