使用java的multithreading概念控制运行Thread

我只想在按下返回键时启动并停止线程。 这里线程停止正常，但我不能再次启动该线程请帮助。 还解释了我使用volatile关键字。这对我来说是有帮助的。

public class Sync extends Thread{ public boolean meth= true; public void run(){ while(meth){ System.out.println("hello"); try { Thread.sleep(1000); } catch (InterruptedException ex) { } } } public void shutdown(){ meth=false; } public void startup(){ meth=true; } } 

主类“

  package com.Sync; import java.util.Scanner; public class SyncMain { public static void main(String[] arg) throws InterruptedException{ Sync hi= new Sync(); hi.start(); System.out.println("press enter to stop"); Scanner d= new Scanner(System.in); d.nextLine(); hi.shutdown(); System.out.println("press enter to start"); d.nextLine(); hi.startup(); } } 

OUTPUT

  run: press enter to stop hello hello hello hello press enter to start BUILD SUCCESSFUL (total time: 6 seconds) 

Answer 1

线程不是可重入的，也就是说，一旦它们退出run方法，它们就无法重新启动，您需要创建一个新实例。

一种解决方案是创建一个新的Sync实例并启动它，但基于您的代码可能更好的解决方案是使用wait锁来“暂停”线程并允许它恢复，例如……

 public static class Sync implements Runnable { private AtomicBoolean keepRunning = new AtomicBoolean(true); private AtomicBoolean pause = new AtomicBoolean(false); private ReentrantLock lckPause = new ReentrantLock(); private Condition conPause = lckPause.newCondition(); public void run() { while (keepRunning.get() && !Thread.currentThread().isInterrupted()) { while (pause.get() && !Thread.currentThread().isInterrupted()) { lckPause.lock(); try { System.out.println("Paused"); conPause.await(); } catch (InterruptedException ex) { ex.printStackTrace(); } finally { lckPause.unlock(); } } if (!Thread.currentThread().isInterrupted()) { System.out.println("hello"); try { Thread.sleep(1000); } catch (InterruptedException ex) { } } } } public void setPaused(boolean paused) { if (pause.get() != paused) { pause.set(paused); if (!paused) { lckPause.lock(); try { conPause.signal(); } finally { lckPause.unlock(); } } } } public void terminate() { keepRunning.set(false); setPaused(false); } } 

这基本上设置了两个循环，一个用于保持线程运行直到它“终止”，一个用于捕获“暂停”条件…

然后你可以做点像……

 public static void main(String[] args) { Sync hi = new Sync(); Thread t = new Thread(hi); t.start(); Scanner d = new Scanner(System.in); System.out.println("press enter to pause"); d.nextLine(); hi.setPaused(true); System.out.println("press enter to resume"); d.nextLine(); hi.setPaused(false); System.out.println("press enter to terminate"); d.nextLine(); hi.terminate(); try { t.join(); } catch (InterruptedException ex) { ex.printStackTrace(); } System.out.println("Has terminated"); } 

简单地运行它…

您应该注意，通常不鼓励直接从Thread扩展，并且通常鼓励使用单独的Runnable ，原因有很多，但是您将来发现最有用的一个原因是Runnable在API的不同部分得到了更广泛的支持（比如Executors API）使它成为一个更灵活的选择

查看Concurrency Trail以获取更多详细信息，尤其是Lock Objects