public TransferToPooledThreadQueue(@NonNls @NotNull String name, @NotNull Condition<?> shutUpCondition, int maxUnitOfWorkThresholdMs, @NotNull Processor<T> processor) { super(name, processor, shutUpCondition, maxUnitOfWorkThresholdMs); myExecutor = new BoundedTaskExecutor(PooledThreadExecutor.INSTANCE, 1); }