andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Use LinkedHashSet instead of HashSet to preserve order of execution

Browse Source
This commit is contained in:
Trustin Lee 2012-05-30 10:17:45 -07:00
parent 9f9045c3b4
commit 47fa2ef2e8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
transport/src/main/java/io/netty/channel/SingleThreadEventLoop.java
View File

@ -6,8 +6,8 @@ import io.netty.util.internal.QueueFactory;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collections; import java.util.Collections;
import java.util.HashSet;
import java.util.Iterator; import java.util.Iterator;
import java.util.LinkedHashSet;
import java.util.List; import java.util.List;
import java.util.Queue; import java.util.Queue;
import java.util.Set; import java.util.Set;
@ -56,7 +56,7 @@ public abstract class SingleThreadEventLoop extends AbstractExecutorService impl
private final Semaphore threadLock = new Semaphore(0); private final Semaphore threadLock = new Semaphore(0);
// TODO: Use PriorityQueue to reduce the locking overhead of DelayQueue. // TODO: Use PriorityQueue to reduce the locking overhead of DelayQueue.
private final Queue<ScheduledFutureTask<?>> scheduledTasks = new DelayQueue<ScheduledFutureTask<?>>(); private final Queue<ScheduledFutureTask<?>> scheduledTasks = new DelayQueue<ScheduledFutureTask<?>>();
private final Set<Runnable> shutdownHooks = new HashSet<Runnable>(); private final Set<Runnable> shutdownHooks = new LinkedHashSet<Runnable>();
/** 0 - not started, 1 - started, 2 - shut down, 3 - terminated */ /** 0 - not started, 1 - started, 2 - shut down, 3 - terminated */
private volatile int state; private volatile int state;
private long lastCheckTimeNanos; private long lastCheckTimeNanos;