要求用线程顺序打A1B2C3....Z2
问题描述
要求用线程顺序打A1B2C3…Z2
思路
- 利用生产者消费者思路,将打印字母进程看做生产者,消费字母消费一个,但这里的消费不是消费的字母,则是消费者消费逻辑为打印数字,利用两个信号量分别为t1Condition 、t2Condition,字符生产者生产打印后通知消费者打印数字, 反之亦然。
代码
/ * 描述: 要求用线程顺序打A1B2C3....Z26 *// * 描述: BlockingQueue的含义 * 标准的生产者消费者模式,当队列中不为null则,.take可以取到数据,不用陷入等待,如果为null,当线程去拿时会发现不能获取到数据 * 这时,该线程就会陷入等待,需要put进去一个参数,才能take到。 */public class T01_06_Question { //设置两个任务队列,允许最大值为1 static BlockingQueue<String> p1 = new ArrayBlockingQueue<String>(1); static BlockingQueue<String> p2 = new ArrayBlockingQueue<String>(1); public static void main(String[] args) { new Thread(() -> { try { for (int i = 0; i < 26; i++) { System.out.print((char) ('A' + i)); //必须有一个先唤醒,不然会发生死锁状态,如果t1 await后唤醒t2,然后马上t2 await两个线程都处于await状态 //将t2Condition唤醒,这时还未释放锁,继续往下执行 //设置p2的值,这时在另外线程中p2线程就可以取到值,不会等待 p2.put("ok"); //在队列中获取一个值,当队列中为空时,这时就会陷入等待,需要另外一个线程放入一个或多个(最大值不为1)才能唤醒 p1.take(); } } catch (InterruptedException e) { e.printStackTrace(); } }).start(); new Thread(() -> { try { for (int i = 0; i < 26; i++) { p1.put("ok"); p2.take(); System.out.print(i + 1); } } catch (Exception e) { e.printStackTrace(); } }).start(); }}
/ * 描述: 要求用线程顺序打A1B2C3....Z26 */public class T01_05_Question { static ReentrantLock lock = new ReentrantLock(); static Condition t1Condition = lock.newCondition(); static Condition t2Condition = lock.newCondition(); public static void main(String[] args) { new Thread(() -> { lock.lock(); try { for (int i = 0; i < 26; i++) { System.out.print((char) ('A' + i)); //必须有一个先唤醒,不然会发生死锁状态,如果t1 await后唤醒t2,然后马上t2 await两个线程都处于await状态 //t1Condition.await(); //将t2Condition唤醒,这时还未释放锁,继续往下执行 t2Condition.signal(); //将自己陷入等待 t1Condition.await(); } //打印完毕,唤醒t2Condition 继续往下执行, t2Condition.signal(); } catch (Exception e) { e.printStackTrace(); } finally { //lock方式加锁,需要将其手动释放 lock.unlock(); } }).start(); new Thread(() -> { lock.lock(); try { for (int i = 0; i < 26; i++) { //将t1Condition唤醒,这时还未释放锁,继续往下执行 t1Condition.signal(); //将自己陷入等待 t2Condition.await(); System.out.print(i + 1); } //打印完毕,唤醒t1Condition 继续往下执行, t1Condition.signal(); } catch (Exception e) { e.printStackTrace(); } finally { //lock方式加锁,需要将其手动释放 lock.unlock(); } }).start(); }}