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

小弟使用多条线程并发请求数据，想实现 只要有一条线程获得数据，其他线程就终止运行 的功能，但不知道怎么控制其他线程终止运行，请各位大神帮忙下下，代码如下：

package test;
public class ThreadTest implements Runnable{
//请求获得的数据
public String reqDate = null;

public static void main(String[] args) {
ThreadTest t = new ThreadTest();
new Thread(t,"线程1").start();
new Thread(t,"线程2").start();
new Thread(t,"线程3").start();
new Thread(t,"线程4").start();
new Thread(t,"线程5").start();
new Thread(t,"线程6").start();

String resultDate = t.getReqDate();
System.out.println("请求数据为："+resultDate);
}

//获得数据,没有数据则等待
public synchronized String getReqDate(){
try {
if(reqDate == null){
wait();
}
} catch (Exception e) {
e.printStackTrace();
}
return reqDate;
}

//如果其他线程都未获得数据，则把请求所得数据赋值给reqDate,并通知其它线程停止数据请求
public synchronized void setReqDate(String date){
if(reqDate == null){
this.reqDate = date;
}
notify();
}

@Override
public void run() {
try {
for(int i = 0;i<30;i++){

System.out.println(i+": "+Thread.currentThread().getName()+"正在请求数据...."+reqDate);
if(i ==10){//如果已经获得数据，则不在发送请求
String date ="K9081";
System.out.println(i+": "+Thread.currentThread().getName()+"已获得数据:"+date);
setReqDate(date);
break;
}
Thread.sleep(3000);
}
} catch (Exception e) {
System.out.println(Thread.currentThread().getName() + " interrupted.");
}

}

}

以上代码的执行结果是(错误结果)：
10: 线程5正在请求数据....null
10: 线程4正在请求数据....null
10: 线程4已获得数据:K9081
10: 线程6正在请求数据....null
10: 线程1正在请求数据....K9081
请求数据为：K9081
10: 线程5已获得数据:K9081
10: 线程3正在请求数据....K9081
10: 线程3已获得数据:K9081
10: 线程1已获得数据:K9081
10: 线程2正在请求数据....K9081
10: 线程2已获得数据:K9081
10: 线程6已获得数据:K9081
正确结果应该是：
10: 线程5正在请求数据....null
10: 线程5已获得数据:K9081
请求数据为：K9081

这边我写了一个例子，两个线程同时获取随机数，当获取的值为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<String, MyThread> threadPool = new HashMap<String, MyThread>();//定义一个线程池

/***
 * 终止所有线程
 */
public static void stopAll() {
Iterator<MyThread> 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();
}
}

项目已经打包上传

温馨提示：内容为网友见解，仅供参考

当前网址：https://22.t2y.org/zz/266t6x2x0.html