———————————TicketsSystem.java—————————————
//多線程實現(xiàn)火車票的售票系統(tǒng)。用同步塊,或著同步方法。
class TicketsSystem
{
public static void main(String[] args) //運行結果與教程中不同,不完全順序,每次運行,順序都不完全一樣。
{
SellThread st=new SellThread();//創(chuàng)建四個線程訪問同一變量tickets。
// 錯 SellThread st1=new SellThread();//若采用創(chuàng)建四個對象的方式,則每個對象中都有100張票。
new Thread(st).start(); //b為false,用的同步方法 。| //同步方法與同步塊共用中,顯示的是只調用了同步塊,而同步方法未被調用。
//b為true,用的同步塊, | //原因,啟動第一個線程后,CPU時間片沒有到期,線程沒有立即運行,接著執(zhí)行b=true。
// | //解決辦法,啟動第一個線程后,執(zhí)行一個睡眠時間,讓CPU時間片到期。
try
{
Thread.sleep(1);
}
catch(Exception e)
{
e.printStackTrace();
}
st.b=true;
new Thread(st).start();
//new Thread(st).start();
//new Thread(st).start();
}
}
class SellThread implements Runnable //程序有點小問題,當剩下最后一張票時,四個線程都運行,可能會出現(xiàn)票數(shù)為0,-1,-2。(系統(tǒng)長時間運行時)。
//可加上一個靜態(tài)方法sleep();它會拋出異常。
{
int tickets=100;
//Object obj=new Object();//也可以聲明一個Thread對象。
Thread th=new Thread();
boolean b=false;
public void run()
{
if(b==false)
{
while(true)
sell();
}
else
{
while(true)
{ //同步方法利用的是this所代表的對象的鎖。
synchronized(this) //采用同步后,顯示正確。此方法兩步:1.聲明Thread對象,2.用synchronized把原方法括起來。
{ //這里換th為this。
///*
if(tickets>0)
{
try
{
Thread.sleep(0);
}
catch(Exception e)
{
e.printStackTrace();
}
System.out.println("th "+Thread.currentThread().getName()+" sell tickets:"+tickets);
tickets--;
}
//*/
}
}
}
}
public synchronized void sell() //每個class也有一個鎖,是這個class所對應的class對象的鎖(監(jiān)視器)。
{
if(tickets>0)
{
try
{
Thread.sleep(1);
}
catch(Exception e)
{
e.printStackTrace();
}
System.out.println("sell "+Thread.currentThread().getName()+" sell tickets:"+tickets);
tickets--;
}
}
}
北京 | 天津 | 上海 | 江蘇 | 山東 |
安徽 | 浙江 | 江西 | 福建 | 深圳 |
廣東 | 河北 | 湖南 | 廣西 | 河南 |
海南 | 湖北 | 四川 | 重慶 | 云南 |
貴州 | 西藏 | 新疆 | 陜西 | 山西 |
寧夏 | 甘肅 | 青海 | 遼寧 | 吉林 |
黑龍江 | 內蒙古 |