@Test public void assertMisfireIfNotRunning() { when(configService.load(true)).thenReturn(JobConfiguration.newBuilder("test_job", 3).cron("0/1 * * * * ?").monitorExecution(true).build()); when(jobNodeStorage.isJobNodeExisted("sharding/0/running")).thenReturn(false); when(jobNodeStorage.isJobNodeExisted("sharding/1/running")).thenReturn(false); when(jobNodeStorage.isJobNodeExisted("sharding/2/running")).thenReturn(false); assertFalse(executionService.misfireIfHasRunningItems(Arrays.asList(0, 1, 2))); }
public boolean misfireIfHasRunningItems(final Collection<Integer> items) { if (!hasRunningItems(items)) { return false; } setMisfire(items); return true; }
ExecutionService { public boolean misfireIfHasRunningItems(final Collection<Integer> items) { if (!hasRunningItems(items)) { return false; } setMisfire(items); return true; } }
ExecutionService { public boolean misfireIfHasRunningItems(final Collection<Integer> items) { if (!hasRunningItems(items)) { return false; } setMisfire(items); return true; } ExecutionService(final CoordinatorRegistryCenter regCenter, final String jobName); }
ExecutionService { public boolean misfireIfHasRunningItems(final Collection<Integer> items) { if (!hasRunningItems(items)) { return false; } setMisfire(items); return true; } ExecutionService(final CoordinatorRegistryCenter regCenter, final String jobName); void registerJobBegin(final ShardingContexts shardingContexts); void registerJobCompleted(final ShardingContexts shardingContexts); void clearAllRunningInfo(); void clearRunningInfo(final List<Integer> items); boolean hasRunningItems(final Collection<Integer> items); boolean hasRunningItems(); boolean misfireIfHasRunningItems(final Collection<Integer> items); void setMisfire(final Collection<Integer> items); List<Integer> getMisfiredJobItems(final Collection<Integer> items); void clearMisfire(final Collection<Integer> items); List<Integer> getDisabledItems(final List<Integer> items); }
ExecutionService { public boolean misfireIfHasRunningItems(final Collection<Integer> items) { if (!hasRunningItems(items)) { return false; } setMisfire(items); return true; } ExecutionService(final CoordinatorRegistryCenter regCenter, final String jobName); void registerJobBegin(final ShardingContexts shardingContexts); void registerJobCompleted(final ShardingContexts shardingContexts); void clearAllRunningInfo(); void clearRunningInfo(final List<Integer> items); boolean hasRunningItems(final Collection<Integer> items); boolean hasRunningItems(); boolean misfireIfHasRunningItems(final Collection<Integer> items); void setMisfire(final Collection<Integer> items); List<Integer> getMisfiredJobItems(final Collection<Integer> items); void clearMisfire(final Collection<Integer> items); List<Integer> getDisabledItems(final List<Integer> items);  }