| 
 | ||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||
public interface WorkQueue
作業キューインタフェース。
作業キューには、チャンク(ビジネスロジックの入力データの集まり)、あるいは ジョブを分割するための分割キーなどが作業単位としてキューイングされる。
作業キューは、JobManger によってファクトリを通して作成され、
 Collector によって取得されて入力を、そのJobManger 
 配下のWorkable オブジェクト(JobWorker など)に渡す
 役割を持つ。
作業キューにエンキューするのは、単一の Collector であるが、
 作業キューからデキューするのは、複数の Workable オブジェクトと
 なる可能性がある。
| メソッドの概要 | |
|---|---|
|  void | close()作業キューを終了する。 | 
|  void | put(WorkUnit workUnit)作業キューに作業単位を追加する。 | 
|  WorkUnit | take()作業キューから作業単位を取得する。 | 
|  void | waitForAllWorkers()この作業キューの作業単位を処理するワーカの終了を待ち合わせる。 | 
| メソッドの詳細 | 
|---|
WorkUnit take()
void close()
void put(WorkUnit workUnit)
workUnit - 追加する作業単位void waitForAllWorkers()
| 
 | ||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||