package program5;

import java.util.Scanner;

public class Test {

 public static void main(String[] args) {
 // TODO Auto-generated method stub
 Scanner sc=new Scanner(System.in);
 int ticks,windows;
 System.out.println("請輸入總票數(shù)：");
 ticks=sc.nextInt();
 System.out.println("請輸入售票窗口數(shù)：");
 windows=sc.nextInt();
 tickets lockThread=new tickets();
 lockThread.setTickets(ticks);
 for(int i=1;i<=windows;i++)
 new Thread(lockThread,"窗口"+i).start();
 }

}

package program5;
import java.util.concurrent.locks.*;
public class tickets implements Runnable {
 private int tickets;
 
 public int getTickets() {
 return tickets;
 }

 public void setTickets(int tickets) {
 this.tickets = tickets;
 }
 private final Lock lock=new ReentrantLock();
 @Override
 public void run() {
 // TODO Auto-generated method stub
 while(true) {
 lock.lock();
 if(tickets>0) {
 try {
 Thread.sleep(100);
 System.out.println(Thread.currentThread().getName()
 +"正在發(fā)售第"+tickets--+"張票");
 }catch(InterruptedException e) {
 e.printStackTrace();
 }finally {
 lock.unlock();
 }
 }
 else {
 System.exit(0);
 }
 }
 }

}