@Test public void disableWorkers() { assertFalse(config.isDisableWorkers()); config.disableWorkers(); assertTrue(config.isDisableWorkers()); config.withDisableWorkers(false); assertFalse(config.isDisableWorkers()); }
public ExecutorConfig<GROUP> disableWorkers() { this.disableWorkers = true; return this; }
ExecutorConfig { public ExecutorConfig<GROUP> disableWorkers() { this.disableWorkers = true; return this; } }
ExecutorConfig { public ExecutorConfig<GROUP> disableWorkers() { this.disableWorkers = true; return this; } ExecutorConfig(); }
ExecutorConfig { public ExecutorConfig<GROUP> disableWorkers() { this.disableWorkers = true; return this; } ExecutorConfig(); @Deprecated ExecutorConfig<GROUP> useAsyncronousTaskDistribution(); @Deprecated ExecutorConfig<GROUP> withAsyncronousTaskDistributionQueueSize(int queueSize); ExecutorConfig<GROUP> withDisableWorkers(boolean disableWorkers); ExecutorConfig<GROUP> disableWorkers(); ExecutorConfig<GROUP> disableFutureSupport(); boolean isFutureSupportEnabled(); ExecutorConfig<GROUP> withThreadCount(int threadCount); ExecutorConfig<GROUP> withTaskIdAdapter(TaskIdAdapter<?,GROUP, ?> taskIdAdapter); ExecutorConfig<GROUP> withMaximumFutureWaitTime(long millis); ExecutorConfig<GROUP> withRecoveryProcessPollInterval(long intervalMillis); ExecutorConfig<GROUP> addTaskResponseListener(TaskResponseListener listener); long getRecoveryProcessPollInterval(); ExecutorConfig<GROUP> withAutoStart(boolean autoStart); ExecutorConfig<GROUP> disableAutoStart(); boolean isDisableWorkers(); int getThreadCount(); @SuppressWarnings("unchecked") TaskIdAdapter<? super Object, GROUP, ?> getTaskIdAdapter(); boolean isAutoStart(); int getMaxThreadPoolSize(); ExecutorConfig<GROUP> withMaxThreadKeepAliveTime(long tti); long getMaxThreadKeepAliveTime(); ExecutorConfig<GROUP> withLoadBalancingConfig(ExecutorLoadBalancingConfig<GROUP> config); ExecutorLoadBalancingConfig<GROUP> getLoadBalancingConfig(); boolean isAsyncronousTaskDistribution(); int getAsyncronousTaskDistributionQueueSize(); long getMaximumFutureWaitTime(); List<TaskResponseListener> getTaskResponseListeners(); }
ExecutorConfig { public ExecutorConfig<GROUP> disableWorkers() { this.disableWorkers = true; return this; } ExecutorConfig(); @Deprecated ExecutorConfig<GROUP> useAsyncronousTaskDistribution(); @Deprecated ExecutorConfig<GROUP> withAsyncronousTaskDistributionQueueSize(int queueSize); ExecutorConfig<GROUP> withDisableWorkers(boolean disableWorkers); ExecutorConfig<GROUP> disableWorkers(); ExecutorConfig<GROUP> disableFutureSupport(); boolean isFutureSupportEnabled(); ExecutorConfig<GROUP> withThreadCount(int threadCount); ExecutorConfig<GROUP> withTaskIdAdapter(TaskIdAdapter<?,GROUP, ?> taskIdAdapter); ExecutorConfig<GROUP> withMaximumFutureWaitTime(long millis); ExecutorConfig<GROUP> withRecoveryProcessPollInterval(long intervalMillis); ExecutorConfig<GROUP> addTaskResponseListener(TaskResponseListener listener); long getRecoveryProcessPollInterval(); ExecutorConfig<GROUP> withAutoStart(boolean autoStart); ExecutorConfig<GROUP> disableAutoStart(); boolean isDisableWorkers(); int getThreadCount(); @SuppressWarnings("unchecked") TaskIdAdapter<? super Object, GROUP, ?> getTaskIdAdapter(); boolean isAutoStart(); int getMaxThreadPoolSize(); ExecutorConfig<GROUP> withMaxThreadKeepAliveTime(long tti); long getMaxThreadKeepAliveTime(); ExecutorConfig<GROUP> withLoadBalancingConfig(ExecutorLoadBalancingConfig<GROUP> config); ExecutorLoadBalancingConfig<GROUP> getLoadBalancingConfig(); boolean isAsyncronousTaskDistribution(); int getAsyncronousTaskDistributionQueueSize(); long getMaximumFutureWaitTime(); List<TaskResponseListener> getTaskResponseListeners();  }