java 多线程并发请求数据，只要有一条线程获得数据，则其他线程终止运行，并打印出获得的数据

java 多线程并发请求数据，只要有一条线程获得数据，则其他线程终止运行，并打印出获得的数据

这边我写了一个例子，两个线程同时获取随机数，当获取的值为68的时候则停止所有进程。

这是目录结构：MyThreadOne和MyThreadTwo是两个线程，TestMain是主函数，MyThread继承Thread类。

MyThread.java

package com.xsx.test;

public class MyThread extends Thread {
public void stopThread() {}
}MyThreadOne.java
package com.xsx.test;
import java.util.Random;


public class MyThreadOne extends MyThread{

private boolean isOK = true;
Random random = new Random();//演示

public void stopThread() {
this.isOK = false;
}

@Override
public void run() {
while(isOK) {
int x = random.nextInt(10000);
System.out.println("Thread One: " + x);
if(x == 68) {
TestMain.stopAll();
System.out.println("My Value is " + x);
break;
}
}
//这边你结合自己的逻辑来写，总之，是通过isOK来控制线程的
}
}MyThreadTwo.java
package com.xsx.test;
import java.util.Random;

public class MyThreadTwo extends MyThread {

private boolean isOK = true;
Random random = new Random();//演示

public void stopThread() {
this.isOK = false;
}

@Override
public void run() {
while(isOK) {
int x = random.nextInt(10000);
System.out.println("Thread Two: " + x);
if(x == 68) {
TestMain.stopAll();
System.out.println("My Value is " + x);
break;
}
}
}

}TestMain.java
package com.xsx.test;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;


public class TestMain {

public static Map threadPool = new HashMap();//定义一个线程池


public static void stopAll() {
Iterator threads = threadPool.values().iterator();
while(threads.hasNext()) {
threads.next().stopThread();
}
threadPool.clear();
}

public static void main(String[] args) {
//实例化两个线程获取到随机数为68时就停止进程，并输出
MyThread thread1 = new MyThreadOne();//实例化线程1
MyThread thread2 = new MyThreadTwo();//实例化线程2
threadPool.put("thread1", thread1);//将线程1放入线程池中
threadPool.put("thread2", thread2);//将线程2放入线程池中
thread1.start();//运行
thread2.start();
}
}项目已经打包上传

你可以设置一个synchronized 的全局变量 ，当有一个获取数据成功就改变这个全局变量的值。如果其他线程发现值变了就终止不就可以了么？你那个notify去通知 是不行的。你可以好好看一下notify的作用。追问谢谢您，按你的方法可以贴出代码我看下效果吗？？追答
上面也是用标志位来终端线程。我写了个强制关闭的，但是你的请求时间太短看不出效果。多运行几遍就能感受到和上面的不同之处。

你这个错误太多了。追问可以帮忙指定吗？谢谢追答1、线程的执行顺序是随机的，所以没有一定正确的结果。
2、在获取数据后没有通知其他线程中止，只是通知了主线程继续执行。追问1、结果只是举个例子而以，不一定就是这个结果
2、因为不知道怎么通知其他线程中止运行，才向大家请教，嘻嘻。。。

如以上回答内容为低俗、色情、不良、暴力、侵权、涉及违法等信息，可以点下面链接进行举报！

点此我要举报以上问答信息