java線程買票案例

A. java 線程池ThreadPoolExecutor 共同完成一個任務

importjava.util.concurrent.ExecutorService;
importjava.util.concurrent.SynchronousQueue;
importjava.util.concurrent.ThreadPoolExecutor;
importjava.util.concurrent.TimeUnit;

publicclassDemo{

publicstaticvoidmain(String[]args){
Ticketticket=newTicket(50);//多線程共享對象
SalersalerA=newSaler("售票員",ticket);
SalersalerB=newSaler("售票員B",ticket);
SalersalerC=newSaler("售票員C",ticket);

ExecutorServicethreadPool=newThreadPoolExecutor(0,10,60L,TimeUnit.MILLISECONDS,
newSynchronousQueue<Runnable>(),newThreadPoolExecutor.DiscardOldestPolicy());

threadPool.execute(salerA);
threadPool.execute(salerB);
threadPool.execute(salerC);
}
}

//售票員
classSalerimplementsRunnable{

privateStringname;
privateTicketticket;

publicSaler(Stringname,Ticketticket){
this.name=name;
this.ticket=ticket;
}

@Override
publicvoidrun(){
while(ticket.getRemain()>0){
ticket.sale(name,1);
try{
Thread.sleep(100);//延遲100ms
}catch(InterruptedExceptione){
}
}
}

}

//車票信息
classTicket{
privateintremain;//余票數量

publicTicket(intremain){
this.remain=remain;
}

//賣票
publicvoidsale(Stringname,intcount){
synchronized(this){//同步鎖，保證一張車票同一時刻只能由一個人賣
if(remain-count>-1){
remain-=count;
System.out.println("["+Thread.currentThread().getName()+"]"+name+"賣出"+count+"張車票，當前余票："
+remain+"張");
}else{
System.out.println("票已賣完。。。");
}
}
}

publicintgetRemain(){
returnremain;
}

publicvoidsetRemain(intremain){
this.remain=remain;
}
}

B. Java語言：Java多線程怎樣創建

線程有兩種創建方式，繼承線程類和實現線程介面。都很簡單，你隨便翻一下java基礎就知道了

C. Java編程 假設有火車票1000張，創建10個線程模擬10個售票點，每個售票點100毫秒售出一張票。

packagetmp;

publicclassTest{
	privatestaticintk=0;//售出票數
	privatestaticintcount=1000;//總票數
	(intn){
		if(k<count){
			k++;
			System.out.println("第"+n+"售票點售出第"+k+"張票");
			returntrue;
		}
		returnfalse;
	}
	{//售票點
		intn;//售票點編號
		publicSellPot(intn){
			this.n=n;
		}
		publicvoidrun(){
			while(sell(n)){
				try{
					Thread.sleep(100);
				}catch(InterruptedExceptione){
					e.printStackTrace();
				}
			}
		}
	}
	publicstaticvoidmain(String[]args){
		for(inti=1;i<=10;i++){
			newSellPot(i).start();
		}
	}
}


//銀行匯款
publicclassTest2{
	privatestaticintk=0;//總匯款
	(intm,inti,intn){
		k+=m;
		System.out.println("第"+n+"個顧客進行第"+(i+1)+"次匯款,銀行接收總匯款"+k);
	}
	{//售票點
		intn;//顧客編號
		publicCostum(intn){
			this.n=n;
		}
		publicvoidrun(){
			for(inti=0;i<3;i++){
				send(100,i,n);//匯款100
				try{
					
					Thread.sleep(100);
				}catch(InterruptedExceptione){
					e.printStackTrace();
				}
			}
		}
	}
	publicstaticvoidmain(String[]args){
		for(inti=1;i<=3;i++){
			newCostum(i).start();
		}
	}
}