exec service hazelcast

execservice.java

  public interface Task<String> extends Callable<String>, Serializable {
        String call();
    }

    public static void main(String[] args) throws InterruptedException, TimeoutException, ExecutionException {
        final HazelcastInstance instance1 = Hazelcast.newHazelcastInstance();
        final HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();


        ExecutorService ss = Executors.newFixedThreadPool(1);

        final Task task = new Task() {
            public Object call() {
                System.out.println("print");
                return "result";
            }
        };

        System.out.println(ss.submit(new Callable<Future<String>>() {
            public Future<String> call() {
                final Member member = instance1.getCluster().getLocalMember();
                final IExecutorService executor = instance1.getExecutorService("default");
                return executor.submitToMember(task, member);
            }

        }).get().get());
    }