java-为什么不在构造函数中启动线程？ 如何终止？

我正在学习如何在Java中使用线程。 我写了一个实现Runnable的类，以同时运行到另一个线程。 主线程处理侦听串行端口，而第二个线程将处理向同一端口发送数据。

public class MyNewThread implements Runnable {

Thread t;

MyNewThread() {

t = new Thread (this, "Data Thread");

t.start();

}

public void run() {

// New Thread code here

}

那里第一个线程像这样启动第二个：

public class Main {

public static void main(String[] args) throws Exception{

new MyNewThread();

// First thread code there

}

}

这可行，但是我的编译器会标出警告语：在构造函数中启动新线程很危险。 为什么是这样？

该问题的第二部分是：如何在一个线程(串行端口侦听线程)中运行循环，并在第二个线程中键入退出命令。 如何获得第一个终止的线程？ 谢谢。

4个解决方案

45 votes

对于第一个问题：在传递this的构造函数中启动线程会逃逸this。这意味着您实际上是在完全构造对象之前给出对您对象的引用。 该线程将在构造函数完成之前启动。 这会导致各种奇怪的行为。

关于第二个问题：在Java中没有强制其他线程停止的方法，因此您将使用一个变量，该线程将检查该变量以知道是否应该停止。 另一个线程将其设置为指示第一个线程将停止。 该变量必须是易失性的，或者所有访问都必须同步，以确保正确发布。 这是一些您想要的代码。

public class MyNewThread implements Runnable {

private final Thread t;

private volatile boolean shouldStop = false;

MyNewThread() {

t = new Thread (this, "Data Thread");

}

public void start() {

t.start();

}

public void stop() {

shouldStop = true;

}

public void run() {

while(!shouldStop)

{

// do stuff

}

}

}

任何想要创建和启动线程的方法都会：

MyNewThread thread = new MyNewThread();

thread.start();

想要停止线程的任何事情都会做：

thread.stop();

Justin Waugh answered 2020-07-05T04:21:07Z

9 votes

让我们看一个基本的例子：

class MyClass implements Runnable{

int a = 0;

String b = null;

public MyClass(){

new Thread(this).start();

b = "Foo";

}

public void run(){

a = b.length(); //can throw NullPointerException

}

}

在这种情况下，可以说MyClass.this逃脱了构造函数。 这意味着该对象可用于引用，但是可能无法创建在构造函数中构建的所有对象。 如果b为final，则将其提升到另一个水平，您希望它可用，但不能保证。 这被称为部分构造的对象，在Java中完全合法。

John Vint answered 2020-07-05T04:21:32Z

0 votes

关于第二个问题，您可以通过2952541841801081085952方法检查第二个线程是否已终止，如果是，请使用2952541841801081085953关键字关闭第一个线程的循环，然后在无需执行任何操作时将终止

public class MyNewThread implements Runnable {

Thread t;

MyNewThread() {

t = new Thread (this, "Data Thread");

t.start();

}

public void run() {

reading code ................

// New Thread code here

}

public class Main {

public static void main(String[] args) throws Exception{

MyNewThread thread = new MyNewThread();

while(true)

{

listening code ...................

if(!thread.t.isAlive())

break;

}

}

}

user1841718 answered 2020-07-05T04:21:52Z

-3 votes

这个问题的第二部分是： 如果我有一个循环运行 线程(串行端口侦听线程) 然后在我的电脑上输入退出命令 第二个线程。 我如何获得第一个 线程终止？

让它一直循环直到达到条件为止。 例如：

public void run() {

while ( !inputConsole.getCommand().equals("exit") ) {

//Do Something

Thread.sleep(1000); //put thread to sleep for 1 second

}

}

Mike Thomsen answered 2020-07-05T04:22:17Z