Java实战之多线程模拟站点售票

public class Ticket {

	public static void main(String[] args) {
		
		for(int i = 1;i <= 5;i++) {
			//创建5个线程并启动他们
			//注意一定要使用Thread类创建线程并使用start方法启动
			//而不是直接创建TicketSeller对象调用run方法!!!!!!
			new Thread(new TicketSeller(i)).start();
		}
	}
}

//售票类，实现Runnable接口，可以作为线程执行对象
class TicketSeller implements Runnable{

	//该售票窗口编号
	private int code;
	
	public TicketSeller(int code) {
		this.code = code;
	}
	
	@Override
	public void run() {
		for(int i = 0;i < 5;i++) {
			System.out.println(code + "号窗口");
			
			//为了使线程能够交替执行，打印完成语句让线程休眠一小会
			try {
				Thread.sleep(300);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
}

//售票类，实现Runnable接口，可以作为线程执行对象
class TicketSeller implements Runnable{

	//票数
	private static int tickets = 100;
	
	//该售票窗口编号
	private int code;
	
	public TicketSeller(int code) {
		this.code = code;
	}
	
	@Override
	public void run() {
			
		//如果有票就一直卖
		while(tickets > 0) {
			System.out.println(code + "_____" + tickets--);
			
			//卖过票之后休眠一小会等待其他线程操作
			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++) {
			//创建5个线程并启动他们
			//注意一定要使用Thread类创建线程并使用start方法启动
			//而不是直接创建TicketSeller对象调用run方法!!!!!!
			new Thread(new TicketSeller(i)).start();
		}
	}
}

//售票类，实现Runnable接口，可以作为线程执行对象
class TicketSeller implements Runnable{

	//票数
	private static int tickets = 100;

	//同步锁
	private static Object lock = new Object();
	
	//该售票窗口编号
	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--);
				
				//卖过票之后休眠一小会等待其他线程操作
				try {
					Thread.sleep(100);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		}
			
	}
	
}

public class Ticket {

	public static void main(String[] args) {
		//创建一个票管理对象，票数为100
		TicketSet ts = new TicketSet(100);
	
		//创建5个线程，使用同一个票管理对象
		for(int i = 1;i <= 5;i++) {
			new Thread(new TicketSeller(ts, i)).start();
		}
	}
}

//票管理类
class TicketSet{
	
	//票数
	private int tickets;
	
	public TicketSet(int tickets) {
		this.tickets = tickets;
	}
	
	
	private boolean hasTicket() {
		return tickets > 0;
	}
	
	//售票方法，使用同步锁，每次只能有一个线程访问该方法
	//返回结果为是否卖出去票
	synchronized public boolean sellTicket(int code) {
		if(hasTicket()) {
			System.out.println(code + "_____" + tickets--);
			return true;
		}else {
			return false;
		}
	}
}

//售票类
class TicketSeller implements Runnable{
	//票管理对象
	private TicketSet ts;

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

	@Override
	public void run() {
		//尝试调用票管理的售票方法，售票成功后休眠一小会
		while(ts.sellTicket(code)){
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}