多线程顺序打印ABC
2018-01-17 20:56
375 查看
有三个线程,每个线程只能打印A,B,C。让线程顺序打印ABC十次
package cn.itcast.java.concurrency;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class ABC {
private static Lock lock = new ReentrantLock();//创建一个共同锁
private static Condition A = lock.newCondition();//创建三个等待队列
private static Condition B = lock.newCondition();
private static Condition C = lock.newCondition();
private static int count = 0;
//三个线程的策略是,A先阻塞自己,B也阻塞自己,C先叫醒A,再阻塞自己,A再叫醒B,执行一遍逻辑,再阻塞自己。B叫醒C
static class ThreadA implements Runnable{
@Override
public void run() {
lock.lock();
try{
for(int i=0;i<10;i++){
if(count%3==0){//确保第一个执行的是A
System.out.println("A");
count++;//确保第二个执行的是B
A.await();//把A,B全部放进阻塞队列,确保除了在锁中的只有一个线程在争夺锁
B.signalAll();
}else{
i--;
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}finally{
lock.unlock();
}
}
}
static class ThreadB implements Runnable{
@Override
public void run() {
lock.lock();
try{
for(int i=0;i<10;i++){
if(count%3==1){
System.out.println("B");
count++;
B.await();
C.signalAll();
}else{
i--;//如果B挣到第一个执行,要把多加的减回去。等于没执行
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}finally{
lock.unlock();
}
}
}
static class ThreadC implements Runnable{
@Override
public void run(){
lock.lock();
try{
for(int i=0;i<10;i++){
if(count%3==2){
System.out.println("C");
count++;
A.signalAll();//先释放A让A争夺锁,此时C还在锁中,不释放,A拿不到。
C.await();
}else{
i--;
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}finally{
lock.unlock();
}
}
}
public static void main(String[] args){
new Thread(new ThreadA(),"A").start();
new Thread(new ThreadB(),"B").start();
new Thread(new ThreadC(),"C").start();
}
}
package cn.itcast.java.concurrency;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class ABC {
private static Lock lock = new ReentrantLock();//创建一个共同锁
private static Condition A = lock.newCondition();//创建三个等待队列
private static Condition B = lock.newCondition();
private static Condition C = lock.newCondition();
private static int count = 0;
//三个线程的策略是,A先阻塞自己,B也阻塞自己,C先叫醒A,再阻塞自己,A再叫醒B,执行一遍逻辑,再阻塞自己。B叫醒C
static class ThreadA implements Runnable{
@Override
public void run() {
lock.lock();
try{
for(int i=0;i<10;i++){
if(count%3==0){//确保第一个执行的是A
System.out.println("A");
count++;//确保第二个执行的是B
A.await();//把A,B全部放进阻塞队列,确保除了在锁中的只有一个线程在争夺锁
B.signalAll();
}else{
i--;
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}finally{
lock.unlock();
}
}
}
static class ThreadB implements Runnable{
@Override
public void run() {
lock.lock();
try{
for(int i=0;i<10;i++){
if(count%3==1){
System.out.println("B");
count++;
B.await();
C.signalAll();
}else{
i--;//如果B挣到第一个执行,要把多加的减回去。等于没执行
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}finally{
lock.unlock();
}
}
}
static class ThreadC implements Runnable{
@Override
public void run(){
lock.lock();
try{
for(int i=0;i<10;i++){
if(count%3==2){
System.out.println("C");
count++;
A.signalAll();//先释放A让A争夺锁,此时C还在锁中,不释放,A拿不到。
C.await();
}else{
i--;
}
}
} catch (InterruptedException e) {
e.printStackTrace();
}finally{
lock.unlock();
}
}
}
public static void main(String[] args){
new Thread(new ThreadA(),"A").start();
new Thread(new ThreadB(),"B").start();
new Thread(new ThreadC(),"C").start();
}
}
相关文章推荐
- java多线程面试题:三个线程顺序打印ABC,重复10次
- Windows多线程按顺序打印ABC
- java多线程---顺序打印ABC的三种实现---volatile方式
- java多线程---顺序打印ABC的三种实现---ReentrantLock方式
- 顺序打印ABC------java多线程的一道经典面试题
- java多线程---顺序打印ABC的三种实现---join方法
- 多线程顺序打印ABC
- JAVA 多线程开篇 -从按顺序打印ABC开始
- 【多线程基础】- 多个线程顺序打印ABC
- 多线程顺序打印ABC
- 多线程(至少三个线程)分别打印A、B、C,要求按ABC的顺序循环打印10次。
- 多线程题 3个线程各打印一种字母,按顺序打印若干次ABC 的2种实现
- 多线程顺序打印ABC的三种实现---join方法
- 练习:利用多线程 按照顺序将 ABC 打印十遍 ,体会 lock 和 condition 的用法
- java 多线程顺序打印ABC
- java多线程顺序打印ABC
- 多线程循环打印ABC
- 多线程练习:三个线程按顺序打印A…
- 菜鸟更要独立思考之二 改进一个不使用wait和notify顺序打印ABC 10次的算法
- 多线程顺序打印