ClusteredExecutorService extends AbstractExecutorService implements TaskExecutor, Executor, MemberListener { public void execute(Runnable command) { if (!(command instanceof ClusteredFutureTask)) { command = new ClusteredFutureTask<Object>(command, null); } command.run(); } ClusteredExecutorService();  ClusteredExecutorService(String invocationServiceName); void execute(Runnable command); void shutdown(); List<Runnable> shutdownNow(); boolean isShutdown(); boolean isTerminated(); boolean awaitTermination(long l, TimeUnit timeUnit); void memberJoined(MemberEvent memberEvent); void memberLeaving(MemberEvent memberEvent); void memberLeft(MemberEvent memberEvent);  }
@Test public void testTaskDistribution() throws Exception { ExecutorService exec = new ClusteredExecutorService(); for (int i = 0; i < 10; i++) { exec.execute(new Logger()); } }