File	Doc	Category	Size	Date	Package
AsynchronousTaskImpl.java	API Doc	JBoss 4.2.1	5699	Fri Jul 13 21:02:30 BST 2007	org.jboss.aspects.asynchronous.concurrent

AsynchronousTaskImpl

• java.lang.Object

Fields Summary
private long	_timeout
private org.jboss.aspects.asynchronous.AsynchronousParameters	_inputParametersImpl
private org.jboss.aspects.asynchronous.AsynchronousUserTask	_oneInstance
private EDU.oswego.cs.dl.util.concurrent.FutureResult	_futureResult
private EDU.oswego.cs.dl.util.concurrent.Callable	_callable
private String	_id

Constructors Summary
AsynchronousTaskImpl(String id, String taskImpl, org.jboss.aspects.asynchronous.AsynchronousParameters inputParametersImpl, long timeout) this._id = id; _futureResult = new FutureResult(); _timeout = timeout; _inputParametersImpl = inputParametersImpl; try { Class aClass = Class.forName(taskImpl); _oneInstance = (AsynchronousUserTask) aClass.newInstance(); } catch (Exception e) { e.printStackTrace(); }
AsynchronousTaskImpl(String id, org.jboss.aspects.asynchronous.AsynchronousUserTask userTask, org.jboss.aspects.asynchronous.AsynchronousParameters inputParametersImpl, long timeout) this._id = id; _futureResult = new FutureResult(); _timeout = timeout; _oneInstance = userTask; _inputParametersImpl = inputParametersImpl;

Methods Summary
public java.lang.Runnable	add() try { if (_timeout == 0) _callable = new AdapterTask(getId(), _inputParametersImpl, _oneInstance); else _callable = new TimedCallableImpl(new AdapterTask(getId(), _inputParametersImpl, _oneInstance), _timeout); return _futureResult.setter(_callable); } catch (Exception e) { throw e; }
public long	getEndingTime() return ((ProcessingTime) _callable).getEndingTime();
public java.lang.String	getId() return _id;
public org.jboss.aspects.asynchronous.AsynchronousParameters	getInputParameters() return _inputParametersImpl;
public org.jboss.aspects.asynchronous.ThreadManagerResponse	getResponse() try { if (isDone()) return (ThreadManagerResponse) _futureResult.get(); else { Object value = _futureResult.get(); if (value != null) return (ThreadManagerResponse) value; else return new ThreadManagerResponseImpl(getId(), NOVALUE, null, null); } } catch (TimeoutException e) { return new ThreadManagerResponseImpl(getId(), TIMEOUT, e.getMessage(), e, getStartingTime(), getEndingTime()); } catch (InterruptedException e) { return new ThreadManagerResponseImpl(getId(), INTERRUPTED, e.getMessage(), e, getStartingTime(), getEndingTime()); } catch (InvocationTargetException e) { int errorCode = INVOCATION; if (e.getTargetException() instanceof EDU.oswego.cs.dl.util.concurrent.TimeoutException) errorCode = TIMEOUT; return new ThreadManagerResponseImpl(getId(), errorCode, e.getTargetException().getMessage(), e.getTargetException(), getStartingTime(), getEndingTime()); }
public long	getStartingTime() return ((ProcessingTime) _callable).getStartingTime();
public org.jboss.aspects.asynchronous.AsynchronousUserTask	getTask() return _oneInstance;
public long	getTimeout() return _timeout;
public boolean	isDone() return _futureResult.isReady();