zion.freetzi.com

/**
 * @(#)Factory.java
 *
 *
 * @author 
 * @version 1.00 2010/7/14
 */
 
public class Factory
{
	private String item;
 
	public Factory()
	{
	}
 
	public synchronized void insertItem(String newItem)
	{
		while(item!=null)
		{
			System.out.print("P >>> Item masih ada. ");
			System.out.println("Producer menunggu.");
 
			try
			{
				/*
				Method wait harus berada dalam blok try catch
				dimana exception yang ditangkap
				adalah InterruptedException
				*/
				wait(); //Berhenti apabila item masih berisi
			}
			catch(InterruptedException ie)
			{
			}
 
			System.out.print("P >>> Item telah kosong. ");
			System.out.println("Producer dapat memasukkan item!");
		}
 
		System.out.println("P >>> Insert : "+newItem);
		this.item = newItem;
		notify();
	}
 
	public synchronized void consumeItem()
	{
		while(item==null)
		{
			System.out.print("C >>> Item masih kosong. ");
			System.out.println("Consumer menunggu.");
 
			try
			{
				/*
				Method wait harus berada dalam blok try catch
				dimana exception yang ditangkap
				adalah InterruptedException
				*/
				wait(); //Berhenti apabila item kosong
			}
			catch(InterruptedException ie)
			{
			}
 
			System.out.print("C >>> Item sudah ada.");
			System.out.println("Consumer dapat mengambil item!");
		}
 
		System.out.println("C >>> Consume: "+item);
		String theItem = item;
 
		item = null;
		notify();
	}
}

/**
 * @(#)Producer.java
 *
 *
 * @author 
 * @version 1.00 2010/7/14
 */
 
public class Producer extends Thread
{
	private Factory factory;
 
	public Producer(Factory factory)
	{
		this.factory = factory;
	}
 
	public void run()
	{
		for(int i=1; i<=5; i++)
		{
			factory.insertItem("Product "+i);
			delay((int)(Math.random()*100));
		}
	}
 
	public void delay(int millis)
	{
		try
		{
			Thread.sleep(millis);
		}
		catch(InterruptedException ie)
		{
		}
	}
}

/**
 * @(#)Consumer.java
 *
 *
 * @author 
 * @version 1.00 2010/7/14
 */
 
 
public class Consumer extends Thread
{
	private Factory factory;
 
	public Consumer(Factory factory)
	{
		this.factory = factory;
	}
 
	public void run()
	{
		for(int i=0; i<5; i++)
		{
			factory.consumeItem();
			delay((int)(Math.random()*100));
		}
	}
 
	public void delay(int millis)
	{
		try
		{
			Thread.sleep(millis);
		}
		catch(InterruptedException ie)
		{
		}
	}
}

/**
 * @(#)MiniFactorySimulation.java
 *
 *
 * @author 
 * @version 1.00 2010/7/14
 */
 
 
public class MiniFactorySimulation
{
	public static void main (String[] args)
	{
		/*Kita membuat satu objek dari class Factory.*/
		Factory factory = new Factory();
 
		/*
		Objek factory yang kita ciptakan diatas
		kita share ke objek producer & consumer
		yang akan kita buat di bawah ini.
		Ingat, objek factory yang ada
		di objek producer & consumer adalah sama.
		*/
 
		Producer producer = new Producer(factory);
		Consumer consumer = new Consumer(factory);
 
		producer.start();
		consumer.start();
	}
}