gistfile1.java

 public static void main(String[] args) throws ExecutionException, InterruptedException {
            final HazelcastInstance instance1 = Hazelcast.newHazelcastInstance();
            final HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();
            IExecutorService exec = instance1.getExecutorService("exec");
            List<Future> flist = new ArrayList<Future>();
            for (int i = 0; i < 10; i++) {
                Future<Object> future = exec.submitToKeyOwner(new TaskCallable(i), i);
                flist.add(future);
            }

            exec.shutdown();
            exec.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);

            for (Future future : flist) {
                System.out.println(future.get());
            }

        }

        static class TaskCallable implements Callable, Serializable {
            int x;

            TaskCallable(int x) {
                this.x = x;
            }

            @Override
            public Object call() throws Exception {
                System.out.println("started:"+x);
                Thread.sleep(1000);
                return x;
            }
        }