如何在Java多线程中从线程2设置线程1的布尔标志

Question

我写一个简单的multithreaded应用程序，它涉及三个线程： Thread-1，Thread-2和main。

Thread-1是 生成* 并馈给的random number生成器类。 *random doubles``Thread-2

Thread-2 消耗了 计算平均值。我的号码已经使用PipedOutputStream该Thread-1饲料用random numbers。Thread-2用途PipedInputStream吃起来random numbers。

问题是：：

如果平均值超过中的1E5 Thread-2，我想Thread-1表示停止产生数字。我有一个boolean flag在Thread-1需要被打开。我该如何实现？

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
import java.util.Random;

//

class NumGen extends Thread {

    PipedOutputStream pos;
    DataOutputStream dos;
    boolean isDone=false;

    public NumGen(PipedOutputStream pos){
        this.pos=pos;
        dos=new DataOutputStream(pos);
    }

    public void run(){
        while (!isDone){
            Random rand = new Random();
            try {
                dos.writeDouble(rand.nextDouble()+100.0);
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
}

class RunningAvg extends Thread {

    PipedInputStream pis;
    DataInputStream dis;
    Double avg;
    int count;
    Double runningTotal;

    public RunningAvg(PipedInputStream pis){
        this.pis=pis;
        dis=new DataInputStream(pis);
            runningTotal=0.0;
    avg=0.0;
    }

    public void run(){
        try {
        while (dis.available()>0){
            count+=1;
            runningTotal+=dis.readDouble();
                avg=runningTotal/count;
                System.out.printf("The average in count no : %s is %s%n",count,avg);
                //if avg>1E5
                 //set NumGen.isDone=true
        }
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }


public class InterThreadComm {

    public static void main(String[] args){


    try {
        PipedOutputStream pos= new PipedOutputStream();
        PipedInputStream pis = new PipedInputStream(pos);
        NumGen ng = new NumGen(pos);
        RunningAvg ra = new RunningAvg(pis);
        ng.start();
        ra.start();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    }


}

PS：该代码将永久运行，而无需在控制台上打印任何内容，我至今仍未弄清原因！！

Answer 1

您可以使用AtomicBoolean并将它传递给两个线程，原子类型是可访问的，抛出多线程也是线程安全的。

首先声明您标记isDone为AtomicBoolean

private AtomicBoolean isDone;

然后声明一个AtomicBoolean对象并将其传递给两个线程

PipedOutputStream pos= new PipedOutputStream();
PipedInputStream pis = new PipedInputStream(pos);
AtomicBoolean isDone = new AtomicBoolean();
NumGen ng = new NumGen(pos, isDone);
RunningAvg ra = new RunningAvg(pis, isDone);
ng.start();
ra.start();

最后，一旦您想停止生成数字，就要求Thread-2设置isDonefalse。