ExecutorConfig { @SuppressWarnings("unchecked") public TaskIdAdapter<? super Object, GROUP, ?> getTaskIdAdapter() { return (TaskIdAdapter<? super Object, GROUP, ?>) taskIdAdapter; } 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();  }
@Test public void testDefaultConfig() { ExecutorConfig defaultConfig = new ExecutorConfig(); TaskIdAdapter adapter = defaultConfig.getTaskIdAdapter(); Object task = new Object(); Assert.assertTrue(adapter.supports(task)); Object group = adapter.getTaskGroup(task); Assert.assertEquals(Integer.class, group.getClass()); Assert.assertEquals(Integer.MIN_VALUE, (int)(Integer)group); }