import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class ConditionTest {
// ExecutorService executorService = Executors.newFixedThreadPool(3);
public static void main(String[] args) {
for (int i = 0; i < 3; i++) {
new Thread(new Runnable() {
@Override
public void run() {
ConditionDetail.print();
}
}).start();
}
}
}
class ConditionDetail {
public static Lock lock = new ReentrantLock();
public static Condition condition = lock.newCondition();
public static int state = 0;
public static void print() {
//AAA BBB CCC
try {
lock.lock();
if (state % 3 != 3) {
printA();
//代码执行到这后 就进入condition里面的等待队列了 退出的条件是
/**
* 上面new了1个Condition对象 那么在condition的源码里 就会只创建一个等待队列
* 当当前3个线程调用condition.await()方法后,线程1 线程2 线程3 就会进入创建的那一个等待队列
* 会使得当前的3个线程释放lock然后加入到等待队列中,串行的等待,
* 直至被signal/signalAll后会使得当前线程从等待队列中移至到同步队列中去,
* 直到再次获得了lock后,才会从await方法返回,或者在等待时被中断会做中断处理,才会向下执行代码。
* 所以这么写是错误的
*/
condition.await();
} else if (state % 3 != 1) {
printB();
condition.await();
} else if (state % 3 != 2) {
printC();
condition.await();
}
condition.signal();
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
state++;
}
private static void printA() {
System.out.println("A");
}
private static void printB() {
System.out.println("B");
}
private static void printC() {
System.out.println("C");
}
}
打印结果 死循环:
转载自原文链接, 如需删除请联系管理员。
原文链接:Condition打印AAABBBCCC的错误写法,转载请注明来源!