Upstream
/
ProtocolLib
mirror of https://github.com/dmulloy2/ProtocolLib.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Replace Integer HashSet with IntOpenHashSet; 

Use isEmpty and make fields final.
This commit is contained in:
Photon-GitHub 2022-07-25 14:08:20 +02:00
parent c40ac8d914
commit ab4977993e
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/java/com/comphenix/protocol/async/AsyncListenerHandler.java
View File

@ -37,6 +37,8 @@ import com.comphenix.protocol.timing.TimedTracker;
import com.google.common.base.Function;
import com.google.common.base.Joiner;
import it.unimi.dsi.fastutil.ints.IntOpenHashSet;
import it.unimi.dsi.fastutil.ints.IntSet;
import org.bukkit.plugin.Plugin;
/**
@ -77,30 +79,30 @@ public class AsyncListenerHandler {
private final AtomicInteger started = new AtomicInteger();
// The packet listener
private PacketListener listener;
private final PacketListener listener;
// The filter manager
private AsyncFilterManager filterManager;
private final AsyncFilterManager filterManager;
private NullPacketListener nullPacketListener;
// List of queued packets
private ArrayBlockingQueue<PacketEvent> queuedPackets = new ArrayBlockingQueue<PacketEvent>(DEFAULT_CAPACITY);
private final ArrayBlockingQueue<PacketEvent> queuedPackets = new ArrayBlockingQueue<>(DEFAULT_CAPACITY);
// List of cancelled tasks
private final Set<Integer> stoppedTasks = new HashSet<Integer>();
private final IntSet stoppedTasks = new IntOpenHashSet();
private final Object stopLock = new Object();
// Processing task on the main thread
private int syncTask = -1;
// Minecraft main thread
private Thread mainThread;
private final Thread mainThread;
// Warn plugins that the async listener handler must be started
private int warningTask;
// Timing manager
private TimedListenerManager timedManager = TimedListenerManager.getInstance();
private final TimedListenerManager timedManager = TimedListenerManager.getInstance();
/**
* Construct a manager for an asynchronous packet handler.
@ -530,7 +532,7 @@ public class AsyncListenerHandler {
*/
private boolean waitForStops() throws InterruptedException {
synchronized (stopLock) {
while (stoppedTasks.size() > 0 && !cancelled) {
while (!stoppedTasks.isEmpty() && !cancelled) {
stopLock.wait();
}
return cancelled;