10.4. 分散実行

Red Hat Data Grid は、標準の JDK ExecutorService インターフェースを介して分散実行を提供します。ローカル JVM で実行されるのではなく、実行用に送信されたタスクは、Red Hat Data Grid ノードのクラスター全体で実行されます。DistributedExecutorService はすべて特定の 1 つのキャッシュにバインドされます。送信されたタスクは、送信されたタスクが DistributedCallable のインスタンスである場合にのみ、その特定のキャッシュからキーと値のペアにアクセスできます。また、ユーザーが他の ExecutorService と同様に一般的な Runnable または Callable を送信することを妨げるものは何もありません。しかし、DistributedExecutorService の名前が示すように、送信された Callable または Runnable を Red Hat Data Grid クラスターの別の JVM に移行し、タスクインカーカーに結果を返す可能性があります。Callable、Runnable、DistributedCallable 提出はすべて他のノードへの移行が生じる可能性があるため、この送信は 336 または Externalizable のいずれかである必要があります。また、呼び出し不可能な値も外部化可能である必要があります。返された値がシリアライズ不可能な場合は、Not336Exception がスローされます。

Red Hat Data Grid の分散タスクエグゼキューターは、Red Hat Data Grid キャッシュノードのデータを実行タスクの入力として使用します。他の分散フレームワークの多くは活用されず、ユーザーは既知の場所から分散タスクの入力を指定する必要があります。さらに、Red Hat Data Grid 分散実行フレームワークのユーザーは、中間および最終的な結果にストアを設定する必要がないため、複雑さとメンテナンスの別のレイヤーが取り除かれます。

この分散実行フレームワークは、Red Hat Data Grid の Data Grid のファクト入力データをすでに負荷分散しています（DIST モードの場合）。入力データはすでに分散されている実行タスクも自動的に分散されるため、ユーザーは明示的に作業タスクを特定の Red Hat Data Grid ノードに割り当てる必要はありません。ただし、このフレームワークでは、ユーザーは分散実行タスクの入力として任意のキャッシュキーのサブセットを指定できます。

public interface DistributedCallable<K, V, T> extends Callable<T> {

   /**
    * Invoked by execution environment after DistributedCallable
    * has been migrated for execution to a specific node.
    *
    * @param cache
    *           cache whose keys are used as input data for this
    *           DistributedCallable task
    * @param inputKeys
    *           keys used as input for this DistributedCallable task
    */
   public void setEnvironment(Cache<K, V> cache, Set<K> inputKeys);

}

public interface DistributedCallable<K, V, T> extends Callable<T> {

   /**
    * Invoked by execution environment after DistributedCallable
    * has been migrated for execution to a specific node.
    *
    * @param cache
    *           cache whose keys are used as input data for this
    *           DistributedCallable task
    * @param inputKeys
    *           keys used as input for this DistributedCallable task
    */
   public void setEnvironment(Cache<K, V> cache, Set<K> inputKeys);

}