ITPub博客

首页 > IT职业 > IT生活 > 多线程通讯轮询卖票了解一下

多线程通讯轮询卖票了解一下

IT生活 作者:megahertz 时间:2021-09-09 10:02:17 0 删除 编辑

package com.xp.test;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class ABC_Lock {

public static void main(String[] args) {    Print print = new Print();    // new Thread(new Runnable() {    // @Override    // public void run() {    // for (int i = 1; i <= 34; i++) {    // print.loopA(i);    // }    // }    // }, "A").start();    // new Thread(new Runnable() {    // @Override    // public void run() {    // for (int i = 1; i <= 33; i++) {    // print.loopB(i);    // }    // }    // }, "B").start();    // new Thread(new Runnable() {    // @Override    // public void run() {    // for (int i = 1; i <= 33; i++) {    // print.loopC(i);    // }    // }    // }, "C").start();    // }    int i = 33;    while (i > 0) {        i--;        new Thread(new Runnable() {            @Override            public void run() {                print.loopA();            }        }, "A").start();        new Thread(new Runnable() {            @Override            public void run() {                print.loopB();            }        }, "B").start();        new Thread(new Runnable() {            @Override            public void run() {                print.loopC();            }        }, "C").start();    }}

}

class Print {
private Lock lock = new ReentrantLock();
private Condition conditionA = lock.newCondition();
private Condition conditionB = lock.newCondition();
private Condition conditionC = lock.newCondition();

int tick = 100;String mark = "a";public void loopA() {    lock.lock();    try {        if (!"a".equals(mark)) {            try {                conditionA.await();            } catch (InterruptedException e) {            }        }        System.out.println(Thread.currentThread().getName() + "完成售票,剩余: " + --tick);        mark = "b";        conditionB.signal();    } finally {        lock.unlock();    }}public void loopB() {    lock.lock();    try {        if (!"b".equals(mark)) {            try {                conditionB.await();            } catch (InterruptedException e) {            }        }        System.out.println(Thread.currentThread().getName() + "完成售票,剩余: " + --tick);        mark = "c";        conditionC.signal();    } finally {        lock.unlock();    }}public void loopC() {    lock.lock();    try {        if (!"c".equals(mark)) {            try {                conditionC.await();            } catch (InterruptedException e) {            }        }        System.out.println(Thread.currentThread().getName() + "完成售票,剩余: " + --tick);        mark = "a";        conditionA.signal();    } finally {        lock.unlock();    }}

}

来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/4419/viewspace-2815478/ ,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2019-08-12

  • 博文量
    93
  • 访问量
    715