dont report negative size in unlucky scheduling scenario

schlawg · Nov 27, 2024 · 8a1f104 · 8a1f104
1 parent ff0c941
commit 8a1f104
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/netty/ActorChannelConnector.scala b/src/main/scala/netty/ActorChannelConnector.scala
@@ -97,8 +97,8 @@ object ActorChannelConnector:
     private val size  = java.util.concurrent.atomic.AtomicInteger()
 
     def add(channel: Channel): Unit =
-      queue.add(channel)
       size.getAndIncrement()
+      queue.add(channel)
 
     def poll(): Option[Channel] =
       val maybeChannel = Option(queue.poll())