jp.go.nict.langrid.commons.runner
クラス RepeatingMultithreadRunner

java.lang.Object
  上位を拡張 jp.go.nict.langrid.commons.runner.MultithreadRunner
      上位を拡張 jp.go.nict.langrid.commons.runner.RepeatingMultithreadRunner

public class RepeatingMultithreadRunner
extends MultithreadRunner

複数スレッドから同時に特定の処理を呼び出す。

バージョン:
$Revision: 8770 $
作成者:
Takao Nakaguchi, $Author: Takao Nakaguchi $

コンストラクタの概要
RepeatingMultithreadRunner(int threadCount, int repeatCount, int retryCount, StatusReporter reporter)
          コンストラクタ。
 
メソッドの概要
protected  Runnable createRunnable(String name, SinglethreadRunnable runnable, CountDownLatch startSignal, CountDownLatch endSignal, List<Exception> exceptions)
           
 int getRepeatCount()
          繰り返し数を取得する。
protected  int getTotalCount()
           
 
クラス jp.go.nict.langrid.commons.runner.MultithreadRunner から継承されたメソッド
done, fault, fault, getDeltaTimeMillis, getExceptions, getRetryCount, getRetryWaitMinMillis, getRetryWaitRangeMillis, getThreadCount, runAndWait, runAndWait, setRetryWaitMinMillis, setRetryWaitRangeMillis
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

コンストラクタの詳細

RepeatingMultithreadRunner

public RepeatingMultithreadRunner(int threadCount,
                                  int repeatCount,
                                  int retryCount,
                                  StatusReporter reporter)
コンストラクタ。

パラメータ:
threadCount - スレッド数
repeatCount - 繰り返し数
retryCount - 失敗時の再試行回数
reporter - StatusReporter
メソッドの詳細

getRepeatCount

public int getRepeatCount()
繰り返し数を取得する。

戻り値:
繰り返し数

getTotalCount

protected int getTotalCount()
オーバーライド:
クラス MultithreadRunner 内の getTotalCount

createRunnable

protected Runnable createRunnable(String name,
                                  SinglethreadRunnable runnable,
                                  CountDownLatch startSignal,
                                  CountDownLatch endSignal,
                                  List<Exception> exceptions)
オーバーライド:
クラス MultithreadRunner 内の createRunnable