test.java

来自「这是操作系统的程序设计」· Java 代码 · 共 29 行

public class Test extends Thread
{
	public static void main(String[] args)
	{
		Buffer bf=new Buffer(10,0,0);
		Semaphore mutex=new Semaphore(1);
		Semaphore full=new Semaphore(0);
		Semaphore empty=new Semaphore(10);
		//new Thread(new Producer("p001",mutex,full,empty,bf)).start();
		Producer p=new Producer("p001",mutex,full,empty,bf);
		new Thread(new Producer("p002",mutex,full,empty,bf)).start();
		new Thread(new Producer("p003",mutex,full,empty,bf)).start();
		new Thread(new Producer("p004",mutex,full,empty,bf)).start();
		new Thread(new Producer("p005",mutex,full,empty,bf)).start();
		try{
			sleep(3000);
		}
		catch(Exception ex)
		{
			ex.printStackTrace();
		}
		new Thread(new Customer("c001",mutex,full,empty,bf)).start();
		new Thread(new Customer("c002",mutex,full,empty,bf)).start();
		new Thread(new Customer("c003",mutex,full,empty,bf)).start();
		new Thread(new Customer("c004",mutex,full,empty,bf)).start();
		new Thread(new Customer("c005",mutex,full,empty,bf)).start();
	}
}