1

我有一个工作进程在数据队列上工作。Atraining worker从training queue. 它继续轮询并寻找写入队列的新数据。

我已经按如下方式实施了工人：

public static void main(String[] args) {
  startTraining()
}

public static boolean startTraining() {
  trainingWorker = new WorkerImpl(config);
  final Thread workerThread = new Thread(trainingWorker);

  WorkerListener listener = new WorkerListener() {
    public void onEvent(WorkerEvent event, Worker worker, String queue, Job job, 
                        Object runner, Object result, Exception ex) {
      if(event.equals(WorkerEvnet.JOB_SUCCESS) {
        //get data
        //process data
        //send data
      }
    }
  }

  trainingWorker.addListener(listener, WorkerEvent.JOB_SUCCESS, WorkerEvent.JOB_FAILURE,
                     WorkerEvent.WORKER_ERROR, WorkerEvent.WORKER_POLL);
  workerThread.start();
  workerThread.join();
}

我希望进行单元测试以查看工作人员是否正确读取数据、正确处理并成功发送数据。问题是因为Thread.join()；对主函数的调用永远不会返回（因为假设工作人员连续运行）。在这种情况下，我不应该为它编写单元测试吗？如果是，我该如何编写其他形式的测试来确保工人按要求工作？

4

1 回答 1

0

您可能希望从代码中删除连接，或者从您的测试用例中启动新线程，这将为您启动工作程序。

显然，您将需要终止工作人员的方法，对于版本，它可能看起来像

public void stopWorker() {
 workerThread.interrupt()
}

所以你需要将你的workerThread本地值转换为一个字段，并使其成为volatile。

于 2012-10-12T14:44:00.000 回答