com.linkedin.parseq

Class AsyncCallableTask<R>

java.lang.Object

com.linkedin.parseq.promise.DelegatingPromise<T>

com.linkedin.parseq.BaseTask<R>

com.linkedin.parseq.AsyncCallableTask<R>

All Implemented Interfaces:

Cancellable, Promise<R>, Task<R>

Deprecated.

As of 2.0.0, replaced by Task.blocking.

@Deprecated
public class AsyncCallableTask<R>
extends BaseTask<R>

This class provides a wrapper to allow synchronous tasks to be treated as asynchronous tasks. This can be used for tasks that are blocking and are not CPU intensive, like JDBC requests. Unlike tasks created with Tasks.callable(String, java.util.concurrent.Callable), tasks wrapped in AsyncCallableTask do not get any special memory consistency guarantees and should not attempt to use shared state. In others, they should act as a stateless function.

To use this class with an engine, register an executor with engine using register(EngineBuilder, java.util.concurrent.Executor)

Author:

Walter Fender (wfender@linkedin.com)

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.parseq.BaseTask

BaseTask.State

Field Summary

Fields inherited from class com.linkedin.parseq.BaseTask

_shallowTraceBuilder, _traceValueProvider

Constructor Summary

Constructors

Constructor and Description
AsyncCallableTask(java.util.concurrent.Callable<R> syncJob) Deprecated. As of 2.0.0, replaced by Task.blocking.
AsyncCallableTask(java.lang.String name, java.util.concurrent.Callable<R> syncJob) Deprecated. As of 2.0.0, replaced by Task.blocking.

Method Summary

Modifier and Type	Method and Description
static void	register(EngineBuilder builder, java.util.concurrent.Executor executor) Deprecated.
protected Promise<R>	run(Context context) Deprecated. This template method is invoked when the task is run.

Methods inherited from class com.linkedin.parseq.BaseTask

cancel, contextRun, getId, getName, getPriority, getSettableDelegate, getShallowTrace, getShallowTraceBuilder, getTrace, getTraceBuilder, markTaskPending, markTaskStarted, setPriority, setTraceValueSerializer, toString, traceFailure, transitionCancel, transitionDone, transitionPending, transitionRun

Methods inherited from class com.linkedin.parseq.promise.DelegatingPromise

addListener, await, await, get, getDelegate, getError, getOrDefault, isDone, isFailed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.linkedin.parseq.Task

action, action, andThen, andThen, andThen, andThen, apply, async, async, async, async, blocking, blocking, callable, callable, failure, failure, flatMap, flatMap, flatten, flatten, map, map, onFailure, onFailure, par, par, par, par, par, par, par, par, recover, recover, recoverWith, recoverWith, shareable, toTry, toTry, transform, transform, value, value, withSideEffect, withSideEffect, withTimeout

Methods inherited from interface com.linkedin.parseq.promise.Promise

addListener, await, await, get, getError, getOrDefault, isDone, isFailed

Constructor Detail

AsyncCallableTask

@Deprecated
public AsyncCallableTask(java.util.concurrent.Callable<R> syncJob)

Deprecated. As of 2.0.0, replaced by Task.blocking.

AsyncCallableTask

@Deprecated
public AsyncCallableTask(java.lang.String name,
                                     java.util.concurrent.Callable<R> syncJob)

Deprecated. As of 2.0.0, replaced by Task.blocking.

Method Detail

register

public static void register(EngineBuilder builder,
                            java.util.concurrent.Executor executor)

Deprecated.

run

protected Promise<R> run(Context context)
                  throws java.lang.Exception

Deprecated.

Description copied from class: BaseTask

This template method is invoked when the task is run.

Specified by:

run in class BaseTask<R>

Parameters:

context - the context to use while running this task

Returns:

a promise that will have its value set when this task is finished

Throws:

java.lang.Exception - if an error occurs while running the task