| 
 | ||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||
java.lang.Objectjp.terasoluna.fw.batch.standard.StandardWorkQueue
jp.terasoluna.fw.batch.commonj.usequeue.WorkManagerTaskWorkQueue
public class WorkManagerTaskWorkQueue
WorkQueue インタフェースのCommonj用実装クラス。
 
 
 この実装では、JDKの BLockingQueue によってキューイングを実現する。
 
 キューへの要素追加、キューからの要素取得の際には、ブロックし続けるのではなく、
 タイムアウト時間だけ試行したあとでJobStatus をチェックし 
 QueueingException 例外をスローする。 
 キューへの要素追加、キューからの要素取得の際に、スレッドがインタラプトされた
 際にもQueueingException 例外をスローする。
 
| フィールドの概要 | |
|---|---|
| private  java.util.List<commonj.work.WorkItem> | workItemListキューの要素の処理結果のリスト。 | 
| private  commonj.work.WorkManager | workManagerワークマネージャ。 | 
| private  long | workTimeoutジョブを開始するまでのタイムアウト(ミリ秒)。 | 
| クラス jp.terasoluna.fw.batch.standard.StandardWorkQueue から継承されたフィールド | 
|---|
| END_MARK | 
| コンストラクタの概要 | |
|---|---|
| WorkManagerTaskWorkQueue(int queueLength,
                         JobStatus jobStatus)コンストラクタ。 | |
| メソッドの概要 | |
|---|---|
|  void | addFutureJobResult(java.util.concurrent.Future<?> futureResult)処理結果に非同期でアクセスするためのフューチャーを追加する。 | 
|  void | addWorkItem(commonj.work.WorkItem workItem)ワーカの処理結果に非同期でアクセスするためのWorkItemを追加する。 | 
|  void | setWorkManager(commonj.work.WorkManager workManager)ワークマネージャを設定する。 | 
|  void | setWorkTimeout(long workTimeout)ジョブを開始するまでのタイムアウト(ミリ秒)の設定。 | 
|  void | waitForAllWorkers()キューの要素を処理するすべてのワーカの終了を待ち合わせる。 | 
| クラス jp.terasoluna.fw.batch.standard.StandardWorkQueue から継承されたメソッド | 
|---|
| close, put, setQueueCheckTimeout, take | 
| クラス java.lang.Object から継承されたメソッド | 
|---|
| clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait | 
| フィールドの詳細 | 
|---|
private java.util.List<commonj.work.WorkItem> workItemList
private commonj.work.WorkManager workManager
private long workTimeout
| コンストラクタの詳細 | 
|---|
public WorkManagerTaskWorkQueue(int queueLength,
                                JobStatus jobStatus)
queueLength - キューの長さjobStatus - ジョブステータス| メソッドの詳細 | 
|---|
public void waitForAllWorkers()
WorkQueue 内の waitForAllWorkersStandardWorkQueue 内の waitForAllWorkerspublic void addWorkItem(commonj.work.WorkItem workItem)
workItem - ワーカの処理結果に非同期でアクセスするためのWorkItempublic void setWorkManager(commonj.work.WorkManager workManager)
workManager - workManager ワークマネージャpublic void setWorkTimeout(long workTimeout)
workTimeout - タイムアウト(ミリ秒)public void addFutureJobResult(java.util.concurrent.Future<?> futureResult)
StandardWorkQueue 内の addFutureJobResultfutureResult - 処理結果に非同期でアクセスするフューチャー| 
 | ||||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||||