Allow blocking calls in WorkerTask#dispose

reactor-core/src/blockHoundTest/java/reactor/core/scheduler/ReactorBlockHoundIntegrationTest.java

@@ -74,26 +74,50 @@ public void shouldDetectBlockingCallsInOperators() {
 	}
 
 	@Test
-	public void shouldNotReportScheduledFutureTask() {
-		for (int i = 0; i < 1_000; i++) {
+	public void shouldNotReportSchedulerScheduledFutureTask() {
+		for (int i = 0; i < 10_000; i++) {
 			Scheduler taskScheduler = Schedulers.newSingle("foo");
 			try {
 				Runnable dummyRunnable = () -> {
 				};
 
 				for (int j = 0; j < 257; j++) {
-					taskScheduler.schedule(dummyRunnable, 200, TimeUnit.MILLISECONDS);
+					taskScheduler.schedule(dummyRunnable, j + 1, TimeUnit.MILLISECONDS);
 				}
 				Disposable disposable = taskScheduler.schedule(dummyRunnable, 1, TimeUnit.SECONDS);
 
-				RaceTestUtils.race(disposable::dispose, disposable::dispose);
+				RaceTestUtils.race(Schedulers.parallel(), disposable::dispose);
 			}
 			finally {
 				taskScheduler.dispose();
 			}
 		}
 	}
 
+	@Test
+	public void shouldNotReportWorkerScheduledFutureTask() {
+		for (int i = 0; i < 10_000; i++) {
+			Scheduler scheduler = Schedulers.newSingle("foo");
+			Scheduler.Worker worker = scheduler.createWorker();
+
+			try {
+				Runnable dummyRunnable = () -> {
+				};
+
+				for (int j = 0; j < 257; j++) {
+					worker.schedule(dummyRunnable, j + 1, TimeUnit.MILLISECONDS);
+				}
+				Disposable disposable = worker.schedule(dummyRunnable, 1, TimeUnit.SECONDS);
+
+				RaceTestUtils.race(Schedulers.parallel(), disposable::dispose);
+			}
+			finally {
+				worker.dispose();
+				scheduler.dispose();
+			}
+		}
+	}
+
 	void expectBlockingCall(String desc, Consumer<CompletableFuture<Object>> callable) {
 		Assertions
 				.assertThatThrownBy(() -> {

reactor-core/src/main/java/reactor/core/scheduler/ReactorBlockHoundIntegration.java

@@ -42,6 +42,7 @@ public void applyTo(BlockHound.Builder builder) {
 
         // Calls ScheduledFutureTask#cancel that may short park in DelayedWorkQueue#remove for getting a lock
         builder.allowBlockingCallsInside(SchedulerTask.class.getName(), "dispose");
+        builder.allowBlockingCallsInside(WorkerTask.class.getName(), "dispose");
 
         builder.allowBlockingCallsInside(ThreadPoolExecutor.class.getName(), "processWorkerExit");
     }