Contoh Produser-Konsumer

Import java.util.*;

public class Producer extends Thread {
   private MessageQueueueue mbox;

   public Producer( MessageQueueueue m ) {
      mbox  = m;
   }

   public void run() {
      Date message;

      while ( true ) {
         int sleeptime = ( int ) ( Server.NAP_TIME * Math.random() );
         System.out.println( "Producer sleeping for " +
            sleeptime + " seconds" );
         try {
            Thread.sleep(sleeptime*1000);
         } catch( InterruptedException e ) {}

         message = new Date();
         System.out.println( "Producer produced " + message );
         mbox.send( message );
      }
   }
}

import java.util.*;

public class Consumer extends Thread {
   private MessageQueueueue mbox;

   public Consumer( MessageQueueueue m ) {
      mbox  = m;
   }

   public void run() {
      Date message;

      while ( true ) {
         int sleeptime = (int) (Server.NAP_TIME * Math.random());
         System.out.println("Consumer sleeping for " +
            sleeptime + " seconds" );
         try {
            Thread.sleep( sleeptime * 1000 );
         } catch( InterruptedException e ) {}

         message = ( Date ) mbox.receive();

         if ( message != null )
            System.out.println("Consumer consume " + message );
      }
   }
}