[java]代码库
package concurrent001;
public class BuyTicket extends Thread {
private int tickets;
private String sellName = "";
public BuyTicket(int num){
this.tickets = num;
}
@Override
public void run() {
while (tickets> 0) {
buyTicket();
}
}
public synchronized void buyTicket(){
if(tickets>0){
System.out.println(Thread.currentThread().getName() + "售出了" + tickets + "号票子");
tickets--;
}
}
public static void main(String[] args) throws InterruptedException {
BuyTicket bt = new BuyTicket(2000);
Thread t1 = new Thread(bt);
Thread t2 = new Thread(bt);
Thread t3 = new Thread(bt);
t1.start();
t2.start();
t3.start();
t1.join();t2.join();t3.join();
System.out.println("end................");
}
}//源代码片段来自云代码http://yuncode.net