Add GlobalEventExecutor#addTask for BlockHound

reactor · May 15, 2019 · 675d8aa · 675d8aa
1 parent 8513dea
commit 675d8aa
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/reactor/netty/resources/NettyBlockHoundIntegration.java b/src/main/java/reactor/netty/resources/NettyBlockHoundIntegration.java
@@ -17,6 +17,7 @@
 
 import io.netty.channel.ChannelInitializer;
 import io.netty.util.concurrent.AbstractEventExecutor;
+import io.netty.util.concurrent.GlobalEventExecutor;
 import io.netty.util.concurrent.SingleThreadEventExecutor;
 import reactor.blockhound.BlockHound;
 import reactor.blockhound.integration.BlockHoundIntegration;
@@ -34,6 +35,8 @@ public void applyTo(BlockHound.Builder builder) {
 
 		//allow set initialization that might use Yield
 		builder.allowBlockingCallsInside(ChannelInitializer.class.getName(), "initChannel");
+		//allow unbounded linked blocking queue
+		builder.disallowBlockingCallsInside(GlobalEventExecutor.class.getName(), "addTask");
 
 		//prevent blocking call in arbitrary netty event executor tasks
 		builder.disallowBlockingCallsInside(AbstractEventExecutor.class.getName(), "safeExecute");