diff --git a/common/src/main/java/io/netty/util/concurrent/SingleThreadEventExecutor.java b/common/src/main/java/io/netty/util/concurrent/SingleThreadEventExecutor.java index 8cd62e0513..89c9510779 100644 --- a/common/src/main/java/io/netty/util/concurrent/SingleThreadEventExecutor.java +++ b/common/src/main/java/io/netty/util/concurrent/SingleThreadEventExecutor.java @@ -45,9 +45,6 @@ public abstract class SingleThreadEventExecutor extends AbstractEventExecutor { private static final InternalLogger logger = InternalLoggerFactory.getInstance(SingleThreadEventExecutor.class); - static final ThreadLocal CURRENT_EVENT_LOOP = - new ThreadLocal(); - 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 taskQueue; final Queue> delayedTaskQueue = new PriorityQueue>(); @@ -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 {