TicketWindowRunnable.java

package concurrent.cpt04;

/**
 * @author: mayuan
 * @desc:
 * @date: 2018/07/01
 */
public class TicketWindowRunnable implements Runnable {
    private int index = 1;

    private final static int MAX = 50;

    private final static Object MUTEX = new Object();

    @Override
    public void run() {
        synchronized (MUTEX) {
            while (index <= MAX) {
                System.out.println(Thread.currentThread() + " 的号码是:" + (index++));
            }
        }
    }

    public static void main(String[] args) {
        final TicketWindowRunnable task = new TicketWindowRunnable();

        Thread t1 = new Thread(task, "1号窗口");

        Thread t2 = new Thread(task, "2号窗口");

        Thread t3 = new Thread(task, "3号窗口");

        Thread t4 = new Thread(task, "4号窗口");

        t1.start();
        t2.start();
        t3.start();
        t4.start();
    }

}