4

run一些线程在其方法中执行一系列操作。当车站关闭时，它会通过 通知所有乘客onStationClosed。当它发生时，线程必须执行一些操作（例如离开站）并且线程必须在没有完成所有剩余操作的情况下终止。

正确的方法是什么：

// 1 - By checking station's state between each operationN?

public class Passenger extends Thread
{
     Station station;
     public void onStationClosed()
     {
          // Do some action before thread terminates
     }
     @Override
     public void run()
     {
         operation1();
         if(station.getState == Station.Closed) return;
         operation2();
         if(station.getState == Station.Closed) return;
         operation3();
         if(station.getState == Station.Closed) return;
         ..
         operationN();
     }
}

// 2 - Throw StationClosedException from onStationClosed and catch it in Station.

public class Passenger extends Thread
{
    Station station;
    public void onStationClosed()
    {
         // Do some action before thread terminates
         throw new StationClosedException();
    }
    @Override
    public void run()
    {
        operation1();
        operation2();
        ..
        operationN();
    }
}
4

1 回答 1

2

第一个解决方案非常好。不过不是很，可以考虑将操作包装在一些小的操作对象中，并station在执行每个操作之前检查状态：

List<Operation> operations = Arrays.asList(new Operation1(), new Operation2(), new Operation3());

for(Operation operation: operations) {
  if(!perform(operation)) {
    return;
  }
}

其中perform()定义如下：

private boolean perform(Operation operation) {
  if(station.getState == Station.Closed)
    return false;
  operation.run();
  return true;
}

有点牵强，但是当操作数量增加时，您会很感激的。

我不太了解异常解决方案。如果您从onStationClosed()回调中抛出该异常，它将被抛出回您的事件发送者线程，而不是Passenger线程。它不会中断你的线程。

但是，您可以使用InterruptedException. 此解决方案与检查站状态非常相似，但您检查的是Thread.isInterrupted()标志。额外的好处：I/O 操作和睡眠会自动中断。你所要做的就是打电话

Thread passenger = new Passenger();
passenger.interrupt();
于 2012-06-09T12:21:08.293 回答