Java多線程實(shí)戰(zhàn)模擬站點(diǎn)售票的功能 附詳細(xì)過(guò)程

//售票類，實(shí)現(xiàn)Runnable接口，可以作為線程執(zhí)行對(duì)象
class TicketSeller implements Runnable{

	//票數(shù)
	private static int tickets = 100;
	
	//該售票窗口編號(hào)
	private int code;
	
	public TicketSeller(int code) {
		this.code = code;
	}
	
	@Override
	public void run() {
			
		//如果有票就一直賣
		while(tickets > 0) {
			System.out.println(code + "_____" + tickets--);
			
			//賣過(guò)票之后休眠一小會(huì)等待其他線程操作
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
			
	}
	
}

public class Ticket {

	public static void main(String[] args) {
		
		for(int i = 1;i <= 5;i++) {
			//創(chuàng)建5個(gè)線程并啟動(dòng)他們
			//注意一定要使用Thread類創(chuàng)建線程并使用start方法啟動(dòng)
			//而不是直接創(chuàng)建TicketSeller對(duì)象調(diào)用run方法!!!!!!
			new Thread(new TicketSeller(i)).start();
		}
	}
}

//售票類，實(shí)現(xiàn)Runnable接口，可以作為線程執(zhí)行對(duì)象
class TicketSeller implements Runnable{

	//票數(shù)
	private static int tickets = 100;

	//同步鎖
	private static Object lock = new Object();
	
	//該售票窗口編號(hào)
	private int code;
	
	public TicketSeller(int code) {
		this.code = code;
	}
	
	@Override
	public void run() {
			
		//如果有票就一直賣
		while(tickets > 0) {
			synchronized (lock) {
				
				//如果票賣完了則跳出
				if(tickets <= 0) {
					break;
				}
				
				System.out.println(code + "_____" + tickets--);
				
				//賣過(guò)票之后休眠一小會(huì)等待其他線程操作
				try {
					Thread.sleep(100);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		}
			
	}
	
}

public class Ticket {

	public static void main(String[] args) {
		//創(chuàng)建一個(gè)票管理對(duì)象，票數(shù)為100
		TicketSet ts = new TicketSet(100);
	
		//創(chuàng)建5個(gè)線程，使用同一個(gè)票管理對(duì)象
		for(int i = 1;i <= 5;i++) {
			new Thread(new TicketSeller(ts, i)).start();
		}
	}
}

//票管理類
class TicketSet{
	
	//票數(shù)
	private int tickets;
	
	public TicketSet(int tickets) {
		this.tickets = tickets;
	}
	
	
	private boolean hasTicket() {
		return tickets > 0;
	}
	
	//售票方法，使用同步鎖，每次只能有一個(gè)線程訪問(wèn)該方法
	//返回結(jié)果為是否賣出去票
	synchronized public boolean sellTicket(int code) {
		if(hasTicket()) {
			System.out.println(code + "_____" + tickets--);
			return true;
		}else {
			return false;
		}
	}
}

//售票類
class TicketSeller implements Runnable{
	//票管理對(duì)象
	private TicketSet ts;

	private int code;
	
	public TicketSeller(TicketSet ts,int code) {
		this.ts = ts;
		this.code = code;
	}

	@Override
	public void run() {
		//嘗試調(diào)用票管理的售票方法，售票成功后休眠一小會(huì)
		while(ts.sellTicket(code)){
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}