1、同步转异步,单条转批量
2、异步线程获取数据
关于Future同步、异步获取线程执行结果分析_红鲤鱼与彩虹的博客-CSDN博客
多任务并行、利用CompletionService计算任务执行结果的和,并优先获取最快执行完毕的任务返回值,使用于无访问顺序的代码。
import java.util.concurrent.*;
/**
* 多任务,用时最小,利用completionService实现
*
* 与 invokeAll不同的是,
* CompletionService.take().get()通过消息队列生产-消费模式获取最先执行完的结果,不会按提交顺序获取结果
*/
public class MultiTaskCompletionService {
public static void main(String[] args) {
ThreadPoolExecutor executor = new ThreadPoolExecutor(
10,
20,
100,
TimeUnit.SECONDS,
new LinkedBlockingQueue<>(100),
new ThreadPoolExecutor.AbortPolicy()); //拒绝策略
CompletionService<Integer> service = new ExecutorCompletionService<>(executor);
long start = System.currentTimeMillis();
for (int i =3;i>0;i--){
service.submit(new Task(i));
}
int sum=0;
for (int i =0;i<3;i++){
try {
int value = service.take().get();
System.out.println("第"+i +"个返回的任务id是:" + value);
sum+=value;
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
System.out.println(sum);
System.out.println(System.currentTimeMillis()-start);
}
}
3、阻塞队列压测性能比较
Java线程池实验:ArrayBlockingQueue和LinkedBlockingQueue性能测试_trigger333的博客-CSDN博客_arrayblockingqueue 性能
ArrayBlockingQueue 和 LinkedBlockingQueue 性能测试与分析_阿拉的梦想的博客-CSDN博客_blockingqueue 效率
结论:
队列设置长有利于提高并发,目前1w他长度还行。
ArrayBlockingQueue 要比LinkedBlockingQueue 效率高。
当线程增加到cpu的个数的时候,吞吐率会达到顶峰,然后再增加线程吞吐率不生反而下降,当然没有很大的下降,这是因为,当线程增多的时候,大部分时间耗费在阻塞和解除阻塞上面了。
4、提高接口性能方法