message5.java

source code about voyager examples of message

// (c) Copyright 1997-2001 Recursion Software Inc.



package examples.message;

import com.recursionsw.ve.*;
import com.recursionsw.ve.message.*;

public class Message5
  {
  public static void main( String args[] )
    {
    try
      {
      Voyager.startup();
      IAlarm alarm = (IAlarm) Factory.create( "examples.message.Alarm", "//localhost:8000" );
      System.out.println( "about to send delay( 5000 )" );
      Result result = Future.invoke( alarm, "delay", new Object[] { new Integer( 5000 ) } );

      // simulate two different application threads blocking on the same future invocation
      Thread thread1 = new ReaderThread( result );
      thread1.start();
      Thread thread2 = new ReaderThread( result );
      thread2.start();
      thread1.join();
      thread2.join();
      }
    catch( Exception exception )
      {
      System.err.println( exception );
      }

    Voyager.shutdown();
    }
  }

class ReaderThread extends Thread
  {
  Result result;

  ReaderThread( Result result )
    {
    this.result = result;
    }

  public void run()
    {
    try
      {
      System.out.println( "waiting..." );
      int value = result.readInt();
      System.out.println( "reader thread gets " + value );
      }
    catch( Exception exception )
      {
      System.err.println( exception );
      }
    }
  }