如何使用线程观察者

Question

我正在进行一个项目，我们在该项目中遇到了线程问题。有一个问题使线程终止，并且线程无法自动重新启动，因此我们想更改当前的实现。我们想出了一个想法来运行一个观察者线程来管理文件处理线程。
请有人建议如何制作监视程序状态的线程以及如何执行此操作的想法。

编辑：所以基本上这就是发生的事情。用户上载一些写入文件共享的媒体文件。移动服务中运行的线程扫描媒体文件并附加到电子邮件。在此过程中，线程终止，无法将媒体连接到电子邮件。

下面是我的servlet和run方法中的代码。

private synchronized void startProcessing() {
    boolean processor = false;
    try {
        Properties mProp = SystemUtil.filterProperties(SystemImpl.getInstance().getApplicationProperties("Media"));
        processor = (Boolean.parseBoolean(mProp.getProperty("processor", "false")) && Boolean.parseBoolean(System.getProperty("RunProcessor", "false")));
    } catch (Exception e) {
        logger.log(Level.INFO, "Unable to get 'processor' value from property file.  Defaulting to false.");
    }
    if (processor) {
        if (null != thread) {
            if (thread.getState().equals(State.TERMINATED)) {
                thread = new Thread(fProc);
            }
        } else {
            thread = new Thread(fProc);
        }
        if (thread.getState().equals(State.NEW)) {
            logger.log(Level.INFO, "processor starting...");
            thread = new Thread(fProc);
            thread.start();
            logger.log(Level.INFO, "processor successfully started.");
        } else {
            logger.log(Level.INFO, "processor thread is already running.");
        }
    } else {
        logger.log(Level.INFO, "processor configured not to run.");
    }
}

public void run() {
    int sleepTime = 10000;
    try {
        sleepTime = Integer.parseInt(mProp.getProperty("ProcessorSleepTime"));
        waitTime = -(Integer.parseInt(mProp.getProperty("ProcessorWaitTime")));
        keepProcessed = Boolean.parseBoolean(mProp.getProperty("KeepProcessed"));
    } catch (Exception ex) {
        logger.log(Level.WARNING, "Unable to read property file.  Using default values.");
    }
    File filePath = new File(MResource.getMRepositoryPath());
    File processingPath = new File(filePath.getPath() + "/" + PROCESS_FOLDER_NAME);
    if (!processingPath.exists()) {
        processingPath.mkdirs();
    }
    File failurePath = new File(filePath.getPath() + "/" + FAILURE_FOLDER_NAME);
    if (!failurePath.exists()) {
        failurePath.mkdirs();
    }
    File processedPath = new File(filePath.getPath() + "/" + PROCESSED_FOLDER_NAME);
    if (!processedPath.exists()) {
        processedPath.mkdirs();
    }
    while (!stopProcessing) {
        isProcessing = true;
        logger.log(Level.FINEST, "Checking for files...");
        try {
            processFiles(filePath, processingPath, failurePath, processedPath);
            try {
                Thread.sleep(sleepTime);
            } catch (InterruptedException e) {
                logger.log(Level.INFO, "Thread sleep interrupted.");
            }
        } catch (Exception e) {
            logger.log(Level.SEVERE, "Error while processing files.", e);
        }
    }
    isProcessing = false;
    stopProcessing = false;
    logger.log(Level.WARNING, " file processor has stopped.");
}

Answer 1

您绝对不应该终止线程。也许你应该让线程等待。要重新启动线程，您需要知道它终止时的确切状态。您必须保存该线程的状态，然后完美地重建正确的线程。所以你的第一个问题可能是“我该怎么做”。如果不全面了解你的程序，就不可能告诉你。但这应该是绝对的最后手段。因为几乎在所有情况下，这都是一个极其可怕的想法。（预计会有更多错误超出您的处理能力）

TLDR；

这是个坏主意。不要终止线程。

编辑：我想你必须先找到杀死线程的bug。如果没有找到，那么无论如何都无法在线程死亡之前保存线程的状态。您可以尝试使用打印语句或调试器

Answer 2

我认为修复原因比重新启动更容易。终止线程的方法只有两种：

1. 正在调用线程。停止（）。这是不推荐的，99.9%不是您的情况

如果你真的需要一个观察者，你可以这样做：

void run() {
    while (true) {
        thread.join();
        thread = new Thread(myRunnable);
        thread.start();
    }
}