Package com.orientechnologies.orient.core.db

Class OScenarioThreadLocal

java.lang.Object

java.lang.ThreadLocal<OScenarioThreadLocal.RunContext>

com.orientechnologies.orient.core.db.OScenarioThreadLocal

public class OScenarioThreadLocal
extends ThreadLocal<OScenarioThreadLocal.RunContext>

Thread local to know when the request comes from distributed requester avoiding loops.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	OScenarioThreadLocal.RUN_MODE
static class	OScenarioThreadLocal.RunContext

Field Summary

Fields

Modifier and Type	Field	Description
static OScenarioThreadLocal	INSTANCE

Constructor Summary

Constructors

Constructor	Description
OScenarioThreadLocal()

Method Summary

Modifier and Type	Method	Description
static <T> Object	executeAsDefault(Callable<T> iCallback)
static Object	executeAsDistributed(Callable<? extends Object> iCallback)
OScenarioThreadLocal.RUN_MODE	getRunMode()
protected OScenarioThreadLocal.RunContext	initialValue()
static OScenarioThreadLocal	instance()
boolean	isRunModeDistributed()
void	setRunMode(OScenarioThreadLocal.RUN_MODE value)

Methods inherited from class java.lang.ThreadLocal

get, remove, set, withInitial

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static volatile OScenarioThreadLocal INSTANCE

Constructor Details

OScenarioThreadLocal

public OScenarioThreadLocal()

Method Details

instance

public static OScenarioThreadLocal instance()

executeAsDefault

public static <T> Object executeAsDefault(Callable<T> iCallback)

executeAsDistributed

public static Object executeAsDistributed(Callable<? extends Object> iCallback)

setRunMode

public void setRunMode(OScenarioThreadLocal.RUN_MODE value)

getRunMode

public OScenarioThreadLocal.RUN_MODE getRunMode()

isRunModeDistributed

public boolean isRunModeDistributed()

initialValue

protected OScenarioThreadLocal.RunContext initialValue()

Overrides:

initialValue in class ThreadLocal<OScenarioThreadLocal.RunContext>