Java - 停止具有共享对象的线程

Question

我想使用共享对象来停止线程。所以我写的代码很简单。

main方法创建并启动线程，然后等待800毫秒，之后将共享对象的属性设置为“false”。

如果共享对象的属性为“true”，则线程处于忙碌等待状态。

代码不起作用(发生无限循环)，似乎存在我无法解释的互斥问题，线程仅读取该属性。

谁能给我解释一下吗？ :)

主要

public class SharedResThreadExt {
public static void main(String args[]) {
    BodyThread[] my_threads = new BodyThread[5];               

    SharedRsrc sh_resource = new SharedRsrc(true);   // shared object dec and alloc

    for (int i = 0; i < my_threads.length; i++) {    // creation and start threads
        my_threads[i] = new BodyThread(sh_resource);         
        my_threads[i].start();
    }

    try{
        Thread.sleep(800);          // wait 800 millisec 
        sh_resource.setFlag(false);  //sets shared object attribute to false
    }
    catch(InterruptedException e){}
}
}

线程主体

class BodyThread extends Thread {                    
private SharedRsrc sr;        

public BodyThread(SharedRsrc sr){
    this.sr = sr;
}

@Override
public void run() {
    System.out.println("Thread: " + getId() + " starts exec.");
    while(sr.getFlag()){}              // busywait if shared object attributeis true  
    System.out.println("Thread: " + getId() + " stopped exec.");
}
}

共享对象

class SharedRsrc{
private boolean flag;

public SharedRsrc(boolean flag){
    this.flag = flag;
}
public boolean getFlag(){
    return this.flag;
}
public void setFlag(boolean flag){
    this.flag = flag;
} 
}

Answer 1

更改共享对象

来自:

class SharedRsrc{
private boolean flag;

public SharedRsrc(boolean flag){
    this.flag = flag;
}
public boolean getFlag(){
    return this.flag;
}
public void setFlag(boolean flag){
    this.flag = flag;
} 
}

致:

   class SharedRsrc{
   private volatile boolean flag;

    public SharedRsrc(boolean flag){
        this.flag = flag;
    }
    public boolean getFlag(){
        return this.flag;
    }
    public void setFlag(boolean flag){
        this.flag = flag;
    } 
    }

或者您可以直接在 SharedResThreadExt 中声明变量，如下所示。

private static volatile boolean flag= false;

如果您不想使用 volatile ，那么第二个选择是使用同步