Kawa/gnu/mapping/Future.java

package gnu.mapping;
import gnu.kawa.io.InPort;
import gnu.kawa.io.OutPort;

public class Future<T> extends Thread implements Lazy<T>
                    // FUTURE: implements java.util.concurrent.Future
{
  public RunnableClosure<T> closure;

  public Future (Procedure action,
		 InPort in, OutPort out, OutPort err)
  {
    closure = new RunnableClosure<T> (action, in, out, err);
  }

  public Future (Procedure action)
  {
    closure = new RunnableClosure<T>(action);
  }

  public static Future make (Procedure action, Environment penvironment,
                             InPort in, OutPort out, OutPort err)
  {
    Environment saveEnv = Environment.setSaveCurrent(penvironment);
    try
      {
        return new Future(action, in, out, err);
      }
    finally
      {
        Environment.restoreCurrent(saveEnv);
      }
  }

  /** Get the CallContext we use for this Thread. */
  public final CallContext getCallContext() {
    return closure.getCallContext();
  }

  public void run() {
    closure.run();
  }

  public T getValue ()
  {
    try
      {
	join ();
      }
    catch (InterruptedException ex)
      {
	throw new RuntimeException ("thread join [force] was interrupted");
      }
    Throwable ex = closure.exception;
    if (ex != null)
	WrappedException.rethrow(ex);
    return closure.result;
  }

  public String toString() {
    StringBuffer buf = new StringBuffer();
    buf.append ("#<future ");
    buf.append(getName());
    buf.append(">");
    return buf.toString();
  }
}