org.eclipse.emf.emfstore.internal.client.common

Class ScopedWorkspaceThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.eclipse.emf.emfstore.internal.client.common.ScopedWorkspaceThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

public class ScopedWorkspaceThreadPoolExecutor
extends ThreadPoolExecutor

This class extend ThreadPoolExecutor, and ensures than when each thread is asked to run its task there is an initialization done on the thread first. This initialization ensures that the static threadlocal ESWorkspaceProviderImpl associated with the ESWorkspaceProviderImpl class is obtained from the thread that is REQUESTING the thread pool to execute behavior, and set upon the thread in the pool which actually EXECUTES the behavior.

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
ScopedWorkspaceThreadPoolExecutor() Default constructor.

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable command) This overridden method ensures that the runnable is updated to have access threadlocal ESWorkspaceProviderImpl from the requesting thread set as the threadlocal ESWorkspaceProviderImpl of the executing thread.

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ScopedWorkspaceThreadPoolExecutor

public ScopedWorkspaceThreadPoolExecutor()

Default constructor.

Method Detail

execute

public void execute(Runnable command)

This overridden method ensures that the runnable is updated to have access threadlocal ESWorkspaceProviderImpl from the requesting thread set as the threadlocal ESWorkspaceProviderImpl of the executing thread.

Specified by:

execute in interface Executor

Overrides:

execute in class ThreadPoolExecutor

See Also:

ThreadPoolExecutor.execute(java.lang.Runnable)