Merge 55a32b5c0f into 6f057b361b

build.gradle

@@ -5,7 +5,7 @@ plugins {
 }
 
 group = 'com.comphenix.protocol'
-version = '5.2.0-SNAPSHOT'
+version = '5.2.0'
 description = 'Provides access to the Minecraft protocol'
 
 def isSnapshot = version.endsWith('-SNAPSHOT')

src/main/java/com/comphenix/protocol/async/AsyncFilterManager.java

@@ -428,7 +428,7 @@ public class AsyncFilterManager implements AsynchronousManager {
             }
             
             // There are no more listeners - queue the packet for transmission
-            signalFreeProcessingSlot(packet);
+            signalFreeProcessingSlot(packet, onMainThread);
 
             PacketSendingQueue queue = getSendingQueue(packet, false);
             
@@ -467,11 +467,18 @@ public class AsyncFilterManager implements AsynchronousManager {
     }
     
     /**
-     * Signal that a packet has finished processing.
+     * Signal that a packet has finished processing. Tries to process further packets
+     * if a processing slot is still free.
      * @param packet - packet to signal.
+     * @param onMainThread whether or not this method was run by the main thread.
      */
-    public void signalFreeProcessingSlot(PacketEvent packet) {
+    public void signalFreeProcessingSlot(PacketEvent packet, boolean onMainThread) {
-        getProcessingQueue(packet).signalProcessingDone();
+    	PacketProcessingQueue queue = getProcessingQueue(packet);
+    	// mark slot as done
+    	queue.signalProcessingDone();
+    	
+    	// start processing next slot if possible
+    	queue.signalBeginProcessing(onMainThread);
     }
     
     /**