|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
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()
|
||||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |