com.alibaba.ttl

Class TtlCallable<V>

java.lang.Object

com.alibaba.ttl.TtlCallable<V>

All Implemented Interfaces:

Callable<V>

public final class TtlCallable<V>
extends Object
implements Callable<V>

TtlCallable decorate Callable, so as to get TransmittableThreadLocal and transmit it to the time of Callable execution, needed when use Callable to thread pool.

Use factory method get(Callable) to get decorated instance.

Since:

0.9.0

Author:

Jerry Lee (oldratlee at gmail dot com)

See Also:

TtlExecutors, Executor, ExecutorService, ThreadPoolExecutor, ScheduledThreadPoolExecutor, Executors, CompletionService, ExecutorCompletionService

Method Summary

Modifier and Type	Method and Description
V	call() wrap method Callable.call().
boolean	equals(Object o)
static <T> TtlCallable<T>	get(Callable<T> callable) Factory method, wrapper input Callable to TtlCallable.
static <T> TtlCallable<T>	get(Callable<T> callable, boolean releaseTtlValueReferenceAfterCall) Factory method, wrapper input Callable to TtlCallable.
static <T> TtlCallable<T>	get(Callable<T> callable, boolean releaseTtlValueReferenceAfterCall, boolean idempotent) Factory method, wrapper input Callable to TtlCallable.
Callable<V>	getCallable()
static <T> List<TtlCallable<T>>	gets(Collection<? extends Callable<T>> tasks) wrapper input Callable Collection to TtlCallable Collection.
static <T> List<TtlCallable<T>>	gets(Collection<? extends Callable<T>> tasks, boolean releaseTtlValueReferenceAfterCall) wrapper input Callable Collection to TtlCallable Collection.
static <T> List<TtlCallable<T>>	gets(Collection<? extends Callable<T>> tasks, boolean releaseTtlValueReferenceAfterCall, boolean idempotent) wrapper input Callable Collection to TtlCallable Collection.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

call

public V call()
       throws Exception

wrap method Callable.call().

Specified by:

call in interface Callable<V>

Throws:

Exception

getCallable

public Callable<V> getCallable()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

get

public static <T> TtlCallable<T> get(Callable<T> callable)

Factory method, wrapper input Callable to TtlCallable.

This method is idempotent.

Parameters:

callable - input Callable

Returns:

Wrapped Callable

get

public static <T> TtlCallable<T> get(Callable<T> callable,
                                     boolean releaseTtlValueReferenceAfterCall)

Factory method, wrapper input Callable to TtlCallable.

This method is idempotent.

Parameters:

callable - input Callable

releaseTtlValueReferenceAfterCall - release TTL value reference after run, avoid memory leak even if TtlRunnable is referred.

Returns:

Wrapped Callable

get

public static <T> TtlCallable<T> get(Callable<T> callable,
                                     boolean releaseTtlValueReferenceAfterCall,
                                     boolean idempotent)

Factory method, wrapper input Callable to TtlCallable.

This method is idempotent.

Parameters:

callable - input Callable

releaseTtlValueReferenceAfterCall - release TTL value reference after run, avoid memory leak even if TtlRunnable is referred.

idempotent - is idempotent or not. true will cover up bugs! DO NOT set, only when you know why.

Returns:

Wrapped Callable

gets

public static <T> List<TtlCallable<T>> gets(Collection<? extends Callable<T>> tasks)

wrapper input Callable Collection to TtlCallable Collection.

Parameters:

tasks - task to be wrapped

Returns:

Wrapped Callable

gets

public static <T> List<TtlCallable<T>> gets(Collection<? extends Callable<T>> tasks,
                                            boolean releaseTtlValueReferenceAfterCall)

wrapper input Callable Collection to TtlCallable Collection.

Parameters:

tasks - task to be wrapped

releaseTtlValueReferenceAfterCall - release TTL value reference after run, avoid memory leak even if TtlRunnable is referred.

Returns:

Wrapped Callable

gets

public static <T> List<TtlCallable<T>> gets(Collection<? extends Callable<T>> tasks,
                                            boolean releaseTtlValueReferenceAfterCall,
                                            boolean idempotent)

wrapper input Callable Collection to TtlCallable Collection.

Parameters:

tasks - task to be wrapped

releaseTtlValueReferenceAfterCall - release TTL value reference after run, avoid memory leak even if TtlRunnable is referred.

idempotent - is idempotent or not. true will cover up bugs! DO NOT set, only when you know why.

Returns:

Wrapped Callable