我应该如何终止Java中的循环子线程？

发布于 2024-08-22 09:29:04 字数 1073 浏览 8 评论 0原文

当我要终止循环线程时，我需要做一些清理工作。例如保存缓冲区以便我稍后可以继续。

PseudoCode: 
private class CalculatePI(Byte[] resume) implements Runnable{
    public void Run(){
       while(true){
          resume=resumeCalculating(resume);
       }
    }
}
Thread calculator= new Thread(new CalculatePI(Byte[] resume)); 
Thread.sleep(200); 
//And now I want to kill calculator

那么实现这个的最佳方法是什么？

使用标志：但问题是如果resumeCalculate()需要（编辑：很长一段时间）永远结束怎么办？
将异常放入计算器，如何？
我可以使用事件监听器之类的吗？我以为它们是用于 GUI
就停止吧？ Thread 类包含某种解构函数，当线程终止时将调用该解构函数，我可以在那里进行处理？

所有者编辑：

我知道我可以使用标志。但请考虑一下：

    public void Run(){
       while(true){
          resume=calculate_stepone(resume); //takes one minute
          resume=calculate_steptwo(resume); //takes two minutes
          resume=calculate_stepthree(resume); //takes three minutes
          resume=calculate_steplast(resume); //takes four minutes
       }
    }

在每行之间放置 if(flag) saveResultsAndExit(); 实用还是美观？我只想扔掉处理了一半的结果，保存之前的结果。

原文

I need to do some clean up work when I am going to terminate a looped thread. Such as saving a buffer so I can continue later.

PseudoCode: 
private class CalculatePI(Byte[] resume) implements Runnable{
    public void Run(){
       while(true){
          resume=resumeCalculating(resume);
       }
    }
}
Thread calculator= new Thread(new CalculatePI(Byte[] resume)); 
Thread.sleep(200); 
//And now I want to kill calculator

So what's the best way implement this?

Use a flag: But the problem is what if resumeCalculating() takes (EDIT: a long time) ~~forever~~ to end?
Put an exception into calculator, how?
Can I use event listeners or something? I thought they were used for GUIs
Just stop it? And Class Thread includes some kind of deconstructor that will be called when the thread is terminated and I could do the processing there?

EDIT by Owner:

I know I can use a flag. But consider this:

    public void Run(){
       while(true){
          resume=calculate_stepone(resume); //takes one minute
          resume=calculate_steptwo(resume); //takes two minutes
          resume=calculate_stepthree(resume); //takes three minutes
          resume=calculate_steplast(resume); //takes four minutes
       }
    }

Is putting a if(flag) saveResultsAndExit(); between every line practical or pretty?
I just want to throw away the half-processed results, and save the previous results.

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

じее 2024-08-29 09:29:04

停止线程的正确方法是打断它。

如果线程中运行的任务正在执行 IO 或正在使用 sleep，那么它将收到信号（此时 InterruptedException）；否则任务应该定期轮询以查看其中断。

让我们调整原始海报的伪代码：

private class CalculatePI(Byte[] resume) implements Runnable{
    public void Run(){
       while(!Thread.interrupted()) { //###
          resume=resumeCalculating(resume);
       }
    }
}
Thread calculator= new Thread(new CalculatePI(Byte[] resume)); 
calculator.run(); //###
//...
//And now I want to kill calculator
calculator.interrupt(); //### sends the signal
//...
calculator.join(); //### actually waits for it to finish

The proper way to stop a thread is to interrupt it.

If the task running in the thread is performing IO or is using sleep then it will receive the signal (InterruptedException at that point); else the task should regularly poll to see if its interrupted.

Lets adapt the original poster's psuedocode:

private class CalculatePI(Byte[] resume) implements Runnable{
    public void Run(){
       while(!Thread.interrupted()) { //###
          resume=resumeCalculating(resume);
       }
    }
}
Thread calculator= new Thread(new CalculatePI(Byte[] resume)); 
calculator.run(); //###
//...
//And now I want to kill calculator
calculator.interrupt(); //### sends the signal
//...
calculator.join(); //### actually waits for it to finish

回复收藏 0 原文