Apache Igniteのノードごとに1つのタスク

Question

Apache Igniteは比較的新しいものです。私はノードにタスクを配布するためにIgnite計算を使用しています。私の目標は、タスクを生成し、 "フリー"のノードにのみこれらを送信するタスクディスパッチャーです。 1つのノードは、一度に1つのタスクしか実行できません。すべてのノードにタスクが実行中の場合、ディスパッチャは次のノードが使用可能になるのを待ってから、次のタスクを実行依頼します。

これをキューとasync Callableで実装できますが、このような何かを行うIgniteオンボードクラスがあるのでしょうか？ ComputeTaskSplitAdapterクラスが私が見る必要があるかどうか分からない、私はその目的を完全には理解していない。

助けてください。

サーバーノードは、タスクの配布中にクラスタに参加したり離れることができます。 タスクは、ノードで異なる時間がかかる可能性があり、サーバーがタスクを完了するとすぐに次のタスクを取得します。

は、ここに私のノードのコードです：

JobStealingCollisionSpi spi = new JobStealingCollisionSpi(); 
    spi.setActiveJobsThreshold(1); 

    IgniteConfiguration cfg = new IgniteConfiguration(); 
    cfg.setCollisionSpi(spi); 

    Ignition.start(cfg); 

そして、これは（テスト用）私の仕事の分配コードです：

JobStealingCollisionSpi spi = new JobStealingCollisionSpi(); 
    spi.setActiveJobsThreshold(1); 

    IgniteConfiguration cfg = new IgniteConfiguration(); 
    cfg.setCollisionSpi(spi); 

    Ignition.setClientMode(true); 
    Ignite ignite = Ignition.start(cfg); 

    for (int i = 0; i < 10; i++) 
    { 
     ignite.compute().runAsync(new IgniteRunnable() 
     { 
      @Override 
      public void run() 
      { 
       System.out.print("Sleeping..."); 
       try 
       { 
        Thread.sleep(10000); 
       } catch (InterruptedException e) 
       { 
        e.printStackTrace(); 
       } 
       System.out.println("Done."); 
      } 
     }); 
    } 

Answer 1

はい、Apache Igniteはそれを直接サポートしています。 https://apacheignite.readme.io/docs/job-scheduling#section-one-at-a-time

すべてのサーバーには独自の待機キューがあり、サーバーは直前のジョブで完了した直後にキュー内の次のジョブに移動することに注意してください。

あなたも、より積極的なスケジュールをご希望の場合は、ここでJob-Stealingスケジュールを見てとることができます。仕事は自分のキューたら、他のサーバー上でジョブキューから有効になって、サーバーがしますまだ仕事を盗むでhttps://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/spi/collision/jobstealing/JobStealingCollisionSpi.html

を空になる。ほとんどのパラメータは設定可能です。