jp.terasoluna.fw.batch.core
インタフェース WorkQueue

既知の実装クラスの一覧:
StandardWorkQueue, WorkManagerTaskWorkQueue

public interface WorkQueue

作業キューインタフェース。

作業キューには、チャンク(ビジネスロジックの入力データの集まり)、あるいは ジョブを分割するための分割キーなどが作業単位としてキューイングされる。

作業キューは、JobManger によってファクトリを通して作成され、 Collector によって取得されて入力を、そのJobManger 配下のWorkable オブジェクト(JobWorker など)に渡す 役割を持つ。

作業キューにエンキューするのは、単一の Collector であるが、 作業キューからデキューするのは、複数の Workable オブジェクトと なる可能性がある。


メソッドの概要
 void close()
          作業キューを終了する。
 void put(WorkUnit workUnit)
          作業キューに作業単位を追加する。
 WorkUnit take()
          作業キューから作業単位を取得する。
 void waitForAllWorkers()
          この作業キューの作業単位を処理するワーカの終了を待ち合わせる。
 

メソッドの詳細

take

WorkUnit take()
作業キューから作業単位を取得する。

戻り値:
キューから取得した作業単位

close

void close()
作業キューを終了する。


put

void put(WorkUnit workUnit)
作業キューに作業単位を追加する。

パラメータ:
workUnit - 追加する作業単位

waitForAllWorkers

void waitForAllWorkers()
この作業キューの作業単位を処理するワーカの終了を待ち合わせる。