diff --git a/src/main/java/io/reactivex/internal/schedulers/IoScheduler.java b/src/main/java/io/reactivex/internal/schedulers/IoScheduler.java index cc22f0d4b1..f6913020a5 100644 --- a/src/main/java/io/reactivex/internal/schedulers/IoScheduler.java +++ b/src/main/java/io/reactivex/internal/schedulers/IoScheduler.java @@ -210,12 +210,6 @@ public void dispose() { tasks.dispose(); // releasing the pool should be the last action - // should prevent pool reuse in case there is a blocking - // action not responding to cancellation -// threadWorker.scheduleDirect(() -> { -// pool.release(threadWorker); -// }, 0, TimeUnit.MILLISECONDS); - pool.release(threadWorker); } }