executor

public static void main(String[] args) {
        HazelcastInstance instance1 = Hazelcast.newHazelcastInstance();
        HazelcastInstance instance2 = Hazelcast.newHazelcastInstance();
        HazelcastInstance instance3 = Hazelcast.newHazelcastInstance();
        HazelcastInstance instance4 = Hazelcast.newHazelcastInstance();

        IExecutorService exec = instance1.getExecutorService("exec");
        exec.submitToAllMembers(new MyCallable());
    }

    static class MyCallable implements Callable, HazelcastInstanceAware, Serializable {

        transient HazelcastInstance instance;

        @Override
        public Object call() throws Exception {
            long threadId = Thread.currentThread().getId();
            System.err.println("instance: " + instance.getName() + ", threadId: " + threadId);
            return null;
        }

        @Override
        public void setHazelcastInstance(HazelcastInstance hazelcastInstance) {
            this.instance = hazelcastInstance;
        }
    }