public class SellThread implements Runnable
{
private int ticketCount = 10;// total tickets, all thread will visit
Object mutex = new Object();// mutex
/**
* selling ticket
*/
public void sellTicket()
{
synchronized (mutex)
{
if (ticketCount > 0)
{
ticketCount--;
System.out.println(Thread.currentThread().getName()
+ "selling..." + ticketCount + "tickets left");
}
else
{
System.out.println("sell done！");
return;
}
}
}
public void run()
{
while (ticketCount > 0)
{
sellTicket();
//sleep 1 millisecond so that each thread
//has the chance to sell ticket
try
{
Thread.sleep(1);
}
catch (InterruptedException e)
{
e.printStackTrace();
}
}
}
public class Test{
public static void main(String[] args)
{
SellThread runTicekt = new SellThread();//one instance will lead to only one object
//,so we have only one mutex
Thread th1 = new Thread(runTicekt, "window1");
Thread th2 = new Thread(runTicekt, "window2");
Thread th3 = new Thread(runTicekt, "window3");
Thread th4 = new Thread(runTicekt, "window4");
th1.start();
th2.start();
th3.start();
th4.start();
try{
th4.join();
th3.join();
th2.join();
th1.join();
}catch (Exception e){
e.printStackTrace();
}
}
}