.prefix("AsynchronousPool")
.size(options.get("AsynchronousPool.Size", 5))
.threadFactory(new DaemonThreadFactory("@Asynchronous", appContext.getId()));
return new AsynchronousPool(
builder.build(options),
options.get("AsynchronousPool.ShutdownWaitDuration", new Duration(1, TimeUnit.MINUTES)));
}
public Object invoke(final Callable<Object> callable, final boolean isVoid) throws Throwable {
final AtomicBoolean asynchronousCancelled = new AtomicBoolean(false);