Remove unused thread local and its getter
This commit is contained in:
parent
7a1550631d
commit
786501d972
@ -45,9 +45,6 @@ public abstract class SingleThreadEventExecutor extends AbstractEventExecutor {
|
||||
private static final InternalLogger logger =
|
||||
InternalLoggerFactory.getInstance(SingleThreadEventExecutor.class);
|
||||
|
||||
static final ThreadLocal<SingleThreadEventExecutor> CURRENT_EVENT_LOOP =
|
||||
new ThreadLocal<SingleThreadEventExecutor>();
|
||||
|
||||
private static final int ST_NOT_STARTED = 1;
|
||||
private static final int ST_STARTED = 2;
|
||||
private static final int ST_SHUTTING_DOWN = 3;
|
||||
@ -61,13 +58,6 @@ public abstract class SingleThreadEventExecutor extends AbstractEventExecutor {
|
||||
}
|
||||
};
|
||||
|
||||
/**
|
||||
* Return the {@link SingleThreadEventExecutor} which belongs the current {@link Thread}.
|
||||
*/
|
||||
public static SingleThreadEventExecutor currentEventLoop() {
|
||||
return CURRENT_EVENT_LOOP.get();
|
||||
}
|
||||
|
||||
private final EventExecutorGroup parent;
|
||||
private final Queue<Runnable> taskQueue;
|
||||
final Queue<ScheduledFutureTask<?>> delayedTaskQueue = new PriorityQueue<ScheduledFutureTask<?>>();
|
||||
@ -105,7 +95,6 @@ public abstract class SingleThreadEventExecutor extends AbstractEventExecutor {
|
||||
thread = threadFactory.newThread(new Runnable() {
|
||||
@Override
|
||||
public void run() {
|
||||
CURRENT_EVENT_LOOP.set(SingleThreadEventExecutor.this);
|
||||
boolean success = false;
|
||||
updateLastExecutionTime();
|
||||
try {
|
||||
|
Loading…
Reference in New Issue
Block a user