Package com.github.kristofa.brave

Class BraveExecutorService

java.lang.Object

com.github.kristofa.brave.BraveExecutorService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.util.concurrent.Executor, java.util.concurrent.ExecutorService

Deprecated.

Replaced by brave.propagation.CurrentTraceContext

@Deprecated
public class BraveExecutorService
extends java.lang.Object
implements java.util.concurrent.ExecutorService, java.io.Closeable

ExecutorService that wraps around an existing ExecutorService and that makes sure the threads are executed in the same Span/Trace context as the the thread that invoked execution of the threads.

It uses ServerTracer and ServerSpanThreadBinder to accomplish this in a transparent way for the user.

It also implements Closeable, calling shutdown(), so the executor service is shut down properly when for example using Spring.

Author:

kristof

See Also:

BraveCallable, BraveRunnable

Constructor Summary

Constructors

Constructor	Description
BraveExecutorService(java.util.concurrent.ExecutorService wrappedExecutor, ServerSpanThreadBinder serverSpanThreadBinder)	Deprecated. use wrap(ExecutorService, Brave) because this constructor loses thread state for local span parents.

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)	Deprecated.
void	close()	Deprecated. Convenience for try-with-resources, or frameworks such as Spring that automatically process this.
void	execute(java.lang.Runnable arg0)	Deprecated.
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0)	Deprecated.
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0, long arg1, java.util.concurrent.TimeUnit arg2)	Deprecated.
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0)	Deprecated.
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0, long arg1, java.util.concurrent.TimeUnit arg2)	Deprecated.
boolean	isShutdown()	Deprecated.
boolean	isTerminated()	Deprecated.
void	shutdown()	Deprecated.
java.util.List<java.lang.Runnable>	shutdownNow()	Deprecated.
java.util.concurrent.Future<?>	submit(java.lang.Runnable arg0)	Deprecated.
<T> java.util.concurrent.Future<T>	submit(java.lang.Runnable arg0, T arg1)	Deprecated.
<T> java.util.concurrent.Future<T>	submit(java.util.concurrent.Callable<T> arg0)	Deprecated.
static BraveExecutorService	wrap(java.util.concurrent.ExecutorService wrappedExecutor, Brave brave)	Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

BraveExecutorService

@Deprecated
public BraveExecutorService(java.util.concurrent.ExecutorService wrappedExecutor,
                            ServerSpanThreadBinder serverSpanThreadBinder)

Deprecated. use wrap(ExecutorService, Brave) because this constructor loses thread state for local span parents.

Method Detail

wrap

public static BraveExecutorService wrap(java.util.concurrent.ExecutorService wrappedExecutor,
                                        Brave brave)

Deprecated.

Since:

3.17

execute

public void execute(java.lang.Runnable arg0)

Deprecated.

Specified by:

execute in interface java.util.concurrent.Executor

awaitTermination

public boolean awaitTermination(long timeout,
                                java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException

Deprecated.

Specified by:

awaitTermination in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

invokeAll

public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0)
                                                             throws java.lang.InterruptedException

Deprecated.

Specified by:

invokeAll in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

invokeAll

public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0,
                                                                    long arg1,
                                                                    java.util.concurrent.TimeUnit arg2)
                                                             throws java.lang.InterruptedException

Deprecated.

Specified by:

invokeAll in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

invokeAny

public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0)
                throws java.lang.InterruptedException,
                       java.util.concurrent.ExecutionException

Deprecated.

Specified by:

invokeAny in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

invokeAny

public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> arg0,
                       long arg1,
                       java.util.concurrent.TimeUnit arg2)
                throws java.lang.InterruptedException,
                       java.util.concurrent.ExecutionException,
                       java.util.concurrent.TimeoutException

Deprecated.

Specified by:

invokeAny in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

isShutdown

public boolean isShutdown()

Deprecated.

Specified by:

isShutdown in interface java.util.concurrent.ExecutorService

isTerminated

public boolean isTerminated()

Deprecated.

Specified by:

isTerminated in interface java.util.concurrent.ExecutorService

shutdown

public void shutdown()

Deprecated.

Specified by:

shutdown in interface java.util.concurrent.ExecutorService

shutdownNow

public java.util.List<java.lang.Runnable> shutdownNow()

Deprecated.

Specified by:

shutdownNow in interface java.util.concurrent.ExecutorService

submit

public <T> java.util.concurrent.Future<T> submit(java.util.concurrent.Callable<T> arg0)

Deprecated.

Specified by:

submit in interface java.util.concurrent.ExecutorService

submit

public java.util.concurrent.Future<?> submit(java.lang.Runnable arg0)

Deprecated.

Specified by:

submit in interface java.util.concurrent.ExecutorService

submit

public <T> java.util.concurrent.Future<T> submit(java.lang.Runnable arg0,
                                                 T arg1)

Deprecated.

Specified by:

submit in interface java.util.concurrent.ExecutorService

close

public void close()

Deprecated.

Convenience for try-with-resources, or frameworks such as Spring that automatically process this.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable