java - v3.8中没有Hazelcast com.hazelcast.core.MultiTask

我使用的是最新的Hazelcast v3.8，在MultiTask软件包或任何其他软件包中找不到com.hazelcast.core。

最新版本的Hazelcast中MultiTask的替代品是什么？

我想控制我的任务在哪些物理节点上运行。我找到了Hazelcast distributed executor in use的一个很好的例子。

您可以看到一个很好的示例：

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

现在，我需要相同的代码，但可以在v3.8上使用。请帮忙）

最佳答案

MultiTask在3.0中被删除，取而代之的是更具表达力，更直接的ExecutorService API。您可以使用以下IExecutorService方法：

void executeOnMembers(Runnable command, Collection<Member> members);
void executeOnMembers(Runnable command, MemberSelector memberSelector);
void executeOnAllMembers(Runnable command);

<T> Map<Member, Future<T>> submitToMembers(Callable<T> task, Collection<Member> members);
<T> Map<Member, Future<T>> submitToMembers(Callable<T> task, MemberSelector memberSelector);
<T> Map<Member, Future<T>> submitToAllMembers(Callable<T> task);

也有上述方法的回调版本。有关更多信息，请参见：
http://docs.hazelcast.org/docs/latest/javadoc/com/hazelcast/core/IExecutorService.html

直接替换echoOnMembers(...)示例的示例是：

public void echoOnMembers( String input, Set<Member> members ) throws Exception {
  HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance();
  IExecutorService executorService =
      hazelcastInstance.getExecutorService( "default" );

  Map<Member, Future<String>> futures = executorService
      .submitToMembers( new Echo( input ), members );

  for ( Future<String> future : futures.values() ) {
    String echoResult = future.get();
    // ...
  }
}

关于java - v3.8中没有Hazelcast com.hazelcast.core.MultiTask，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/42674840/