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();
		}
	}
}