This post originated from an RSS feed registered with Java Buzz by Talip Ozturk. Original Post: Hazelcast 1.2beta: Distributed ExecutorService Feed Title: Shared Memory Feed URL: http://www.jroller.com/talipozturk/feed/entries/rss Feed Description: about java, jcache, jini, javaspaces, distributed data structures and a little bit of me and life. Latest Java Buzz Posts Latest Java Buzz Posts by Talip Ozturk Latest Posts From Shared Memory

• on a specific cluster member you choose.
• on the member owning the key you choose.
• on the member Hazelcast will pick.
• on all or subset of the cluster members.

Sample code will make it more understandable so let say you have a Echo callable that you want to execute:

import java.util.concurrent.Callable;
import java.io.Serializable;

public class Echo implements Callable, Serializable {
       String input = null;
       public Echo() {
               super();
       }
       public Echo(String input) {
               super();
               this.input = input;
       }
       public String call() {
               return Hazelcast.getCluster().getLocalMember().toString() + ":"
                               + input;
       }
}

Here are the methods to execute the Echo in a distributed way:

import com.hazelcast.core.Member;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.MultiTask;
import com.hazelcast.core.DistributedTask;
import java.util.concurrent.ExecutorService;   
import java.util.concurrent.FutureTask;   
import java.util.concurrent.Future;   
import java.util.Set;

public void echoOnTheMember(String input, Member member) throws Exception {
       FutureTask task = new DistributedTask(new Echo(input), member);
       ExecutorService executorService = Hazelcast.getExecutorService();
       executorService.execute(task);
       String echoResult = task.get();
}

public void echoOnTheMemberOwningTheKey(String input, Object key) throws Exception {
       FutureTask task = new DistributedTask(new Echo(input), key);
       ExecutorService executorService = Hazelcast.getExecutorService();
       executorService.execute(task);
       String echoResult = task.get();
}

public void echoOnSomewhere(String input) throws Exception { 
       ExecutorService executorService = Hazelcast.getExecutorService();
       Future task = executorService.submit(new Echo(input));
       String echoResult = task.get();
}

public void echoOnMembers(String input, Set members) throws Exception {
       MultiTask task = new MultiTask(new Echo(input), members);
       ExecutorService executorService = Hazelcast.getExecutorService();
       executorService.execute(task);
       Collection result = task.get(); 
} 

I plan to add couple of more features before the 1.2final such as executing multiple callable|runnables in shot. Make sure you check out the documentation at hazelcast.com for complete list of features and more sample code.

Feedback is always welcomed (oztalip@gmail.com or hazelcast@googlegroups.com)