多线程问题 - V2EX

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 1940 天前的主题，其中的信息可能已经有所发展或是发生改变。

多线程情况下，根据业务唯一业务 id 查询 a,b,c 三个表，并且将三个表数据集成起来怎么显示

多线

业务

程

查询

15 条回复 • 2019-08-16 09:44:13 +08:00

1424659514

2019-08-06 13:38:49 +08:00

emmmmmm, 只是查询的话跟多线程没太大关系呀

snappyone

2019-08-06 13:41:08 +08:00

Countdownlatch 并发查询，然后代码里面合并数据

dovme

2019-08-06 14:33:16 +08:00

@snappyone #2 +1

zardly666

2019-08-06 14:36:28 +08:00

线程用 Callable+Future 返回数据，三个线程都返回值以后在 Countdownlatch 倒计时完毕后把数据合并起来

hunterzhang86

2019-08-06 15:06:24 +08:00

我一般用 LinsteningExecutorService 和 CountDownLatch 结合起来做，在 onSuccess 和 onFailure 里面使用 countDown()方法，这样便于捕获到异常情况。

woxiangjingjing

2019-08-06 16:18:00 +08:00

@zardly666 countdownlatch 是在哪用啊，这种写对不对
public class test {

public static void main(String[] args) {
ExecutorService executor = Executors.newCachedThreadPool();
A a = new A();
B b = new B();
C c = new C();

Future<Integer> result = executor.submit(a);
Future<Integer> result1 = executor.submit(b);
Future<Integer> result2 = executor.submit(c);
executor.shutdown();

try {
Thread.sleep(1000);
} catch (InterruptedException e1) {
e1.printStackTrace();
}

System.out.println("主线程在执行任务");

try {
System.out.println("task 运行结果"+result.get()+result1.get()+result2.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}

System.out.println("所有任务执行完毕");
}
}

class A implements Callable<Integer> {
@Override
public Integer call() throws Exception {
System.out.println("查询 A 表数据");
Thread.sleep(3000);
int sum = 0;
for(int i=0;i<100;i++)
sum += i;
return sum;
}
}
class B implements Callable<Integer> {
@Override
public Integer call() throws Exception {
System.out.println("查询 B 表数据");
Thread.sleep(3000);
int sum = 0;
for(int i=0;i<100;i++)
sum += i;
return sum;
}
}
class C implements Callable<Integer> {
@Override
public Integer call() throws Exception {
System.out.println("查询 C 表数据");
Thread.sleep(3000);
int sum = 0;
for(int i=0;i<100;i++)
sum += i;
return sum;
}
}

lihongjie0209

2019-08-06 16:23:30 +08:00

前端的 promise java 中的 completeableFuture

zardly666

2019-08-06 16:33:58 +08:00

@woxiangjingjing CountDownLatch 是一个类，要传参数

import java.util.concurrent.*;
public class Count {
public static void main(String[] args) {
ExecutorService executor = Executors.newCachedThreadPool();
//定时器要传参数（几个线程完成以后再执行主线程）
CountDownLatch latch = new CountDownLatch(3);
//每个线程要把 CountDownLatch 传进去，每个线程完成以后倒计时-1
A a = new A(latch);
B b = new B(latch);
C c = new C(latch);

Future<Integer> result = executor.submit(a);
Future<Integer> result1 = executor.submit(b);
Future<Integer> result2 = executor.submit(c);

executor.shutdown();
//3 个线程都完成以后就会执行主线程
try {
Thread.sleep(1000);
} catch (InterruptedException e1) {
e1.printStackTrace();
}

System.out.println("主线程在执行任务");

try {
System.out.println("task 运行结果"+result.get()+result1.get()+result2.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
System.out.println("所有任务执行完毕");

}
}

import java.util.concurrent.Callable;
import java.util.concurrent.CountDownLatch;

public class A implements Callable<Integer>{
CountDownLatch latch;
public A(CountDownLatch latch) {
this.latch = latch;
}

@Override
public Integer call() throws Exception {
System.out.println("查询 A 表数据");
Thread.sleep(3000);
int sum = 0;
for(int i=0;i<100;i++)
sum += i;
latch.countDown();
return sum;
}
}

你的 CountDownLatch 用的不对，再看看相关知识吧~

zardly666

2019-08-06 16:40:46 +08:00

还有求和相加运算括起来，不然输出的是字符串相加了就成 495049504950 了
System.out.println("task 运行结果"+(result.get()+result1.get()+result2.get()));

latch.countDown();
每个线程中的倒计时减少是这个