问题描述:三个线程,第一个线程只能打印A,第二个线程只能打印B,第三个线程只能打印C,如何循环打印出一定次数的ABC?
例如:打印循环3次,输出为ABCABCABC
lock方式:
public class PrintABC { private Integer times; private Integer flag; private Lock lock; public PrintABC(Integer times, ReentrantLock lock) { this.flag = 0; this.times = times; this.lock = lock; } public void printA() { print("A", 0); } public void printB() { print("B", 1); } public void printC() { print("C", 2); } public void print(String s, int value) { for (int i = 0; i < times;) { lock.lock(); if (flag == value) { System.out.printf("%s", s); flag = (flag + 1) % 3; i++; } lock.unlock(); } } public static void main(String[] args) { PrintABC printABC = new PrintABC(new Integer(10), new ReentrantLock()); new Thread(printABC::printA).start(); new Thread(printABC::printB).start(); new Thread(printABC::printC).start(); } }
lock + condition方式:
public class PrintABC2 { private Lock lock; private int flag; private int times; Condition[] condition = new Condition[3]; public PrintABC2(int times, Lock lock) { this.lock = lock; this.times = times; this.flag = 0; for (int i = 0; i < 3; i++) { this.condition[i] = lock.newCondition(); } } public void printA() { print("A", 0); } public void printB() { print("B", 1); } public void printC() { print("C", 2); } public void print(String s, int value) { try { for (int i = 0; i < times; i++) { lock.lock(); if (flag != value) { condition[value].await(); } System.out.printf("%s", s); flag = (flag + 1) % 3; condition[flag].signal(); lock.unlock(); } } catch (InterruptedException e) { System.out.println(e); } } public static void main(String[] args) { PrintABC2 printABC = new PrintABC2(new Integer(10), new ReentrantLock()); new Thread(printABC::printA).start(); new Thread(printABC::printB).start(); new Thread(printABC::printC).start(); } }
信号量方式:
public class PrintABC3 { private int times; private Semaphore[] semaphores = new Semaphore[] {new Semaphore(1), new Semaphore(0), new Semaphore(0)}; public PrintABC3(int times) { this.times = times; } public void printA() { print("A", 0); } public void printB() { print("B", 1); } public void printC() { print("C", 2); } public void print(String s, int currendId) { int nextId = (currendId + 1) % 3; try { for (int i = 0; i < times; i++) { semaphores[currendId].acquire(); System.out.printf("%s", s); semaphores[nextId].release(); } } catch (InterruptedException e) { System.out.println(e); } return; } public static void main(String[] args) { PrintABC3 printABC = new PrintABC3(10); new Thread(printABC::printA).start(); new Thread(printABC::printB).start(); new Thread(printABC::printC).start(); } }