在子类实例中看不到修改受保护的字段值

Question

这是我遇到的一个奇怪的情况。我有一个定义受保护字段的抽象基类。还有一个修改字段的公共方法。然后，我有基类的一些子类使用字段。

我注意到，当我调用超类方法来修改字段时，对字段值的更改似乎不会“贯彻”到子类的实例中。

需要提到的另一件事是抽象类（以及它的子类）实现了runnable。我不认为这会对我看到的东西有影响，但多线程不是我的专长。

抽象基类：

public abstract class AbstractWidget implements Runnable {
  // Other fields and methods omitted for brevity.
  protected boolean running;

  public void shutDown() {
    running = false;
  }
}

子类：

public class ConcreteWidget extends AbstractWidget {
  // Other fields and methods omitted for brevity.

  @Override
  public void run() {
    running = true;
    while (running) {
      // ...
    }
    logger.info("Shutting down");
  }
}

因此，当我最终调用shutdown()方法时，线程中运行的子类实例不会从它的循环中中断并返回。

我曾经多次使用从“外部”修改布尔字段来停止“永远”线程的技术。我不明白这里发生了什么。

更新：

下面是一个被调用的代码示例。

ConcreteWidget widet = new ConcreteWidget(...);
thread = new Thread(widget);
thread.start();
logger.info("Started");

...

logger.debug("shutting down");
widget.shutDown();

try {
  logger.debug("doing join on thread");
  thread.join();
  logger.debug("returned from join");
} catch (InterruptedException e) {
  logger.error("Exception", e);
}

对join()的调用永远不会返回。

更新：

按照要求，我包含了我希望是完整的（足够的）代码示例，就像我目前所拥有的一样。注意：我采纳了这个建议，将受保护的boolean更改为atomicboolean。

public abstract class AbstractWidget implements Runnable {
  protected final AtomicBoolean   running  = new AtomicBoolean(true);
  public void shutDown() {
    running.set(false);
  }
}


public class ConcreteWidget extends AbstractWidget {
  @Override
  public void run() {
    while (running.get()) {
      // ... do stuff (including calling process() below)
    }
  }
  private void process() {
    try {
      // ... do stuff
    } catch (IOException e) {
      logger.error("Exception", e);
      running.set(false);
      return;
    }
  }
}

在“主”逻辑中：

  private void startService() {
    widget = new ConcreteWidget(...);
    thread = new Thread(widget);
    thread.start();
    logger.info("Started");
  }

  public void close() {
    logger.debug("shutting down service");
    widget.shutDown();

    try {
      logger.debug("doing join on service thread");
      thread.join();
      logger.debug("returned from join");
    } catch (InterruptedException e) {
      logger.error("Exception", e);
    }
  }

顺便说一句，它还是不行。

Answer 1

是否在Thread.Start()；之后立即运行Widget.Shutdown()；？

可能widget.shutdown()；在running=true之前运行；run()方法中的代码

Answer 2

你的问题其实很简单。在调用widget.shutdown()；时，线程尚未实际启动，因此当线程实际启动时，它将running设置回true，并且从未停止。不使用running终止循环，而是使用单独的stopped变量。

public abstract class AbstractWidget implements Runnable {
  // Other fields and methods omitted for brevity.
  private volatile boolean running = false;
  private valatile boolean stopped = false;

  public boolean isRunning() {
    return running;
  }

  public boolean hasStopped() {
    return stopped;
  }

  public void shutDown() {
    stopped = true;
  }
}

public class ConcreteWidget extends AbstractWidget {
  // Other fields and methods omitted for brevity.

  @Override
  public void run() {
    running = true;
    while (!stopped) {
      // ...
    }
    running = false;
    logger.info("Shutting down");
  }
}

使用此设置，您可能希望在停止之前等待一段时间，否则循环将永远不会运行。

ConcreteWidget widet = new ConcreteWidget(...);
thread = new Thread(widget);
thread.start();
logger.info("Started");
...

try {
  Thread.sleep(500); // <--
} catch (Exception e) {}
logger.debug("shutting down");
widget.shutDown();

try {
  logger.debug("doing join on thread");
  thread.join();
  logger.debug("returned from join");
} catch (InterruptedException e) {
  logger.error("Exception", e);
}