Java多线程提交按照时间顺序获取线程结果详解流程

Maven依赖

其实要不要无所谓。主要是为了方便。

        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.7.15</version>
        </dependency>

代码

不废话，上代码。

package com.hy.csdn.tools;

import cn.hutool.core.thread.ThreadUtil;

import java.util.Arrays;
import java.util.List;
import java.util.concurrent.*;
import java.util.function.Consumer;

/**
 * @author huyi
 * @date 2021/11/1 下午2:22
 */
public class ThreadPriorityUtil {
  private static final ExecutorService EXECUTOR_SERVICE = Executors.newFixedThreadPool(100);

    /**
     * 提交多个任务
     * @param tasks 任务
     * @param consumer 结果消费
     * @param <T> 泛型
     */
  public static <T> void submit(List<Callable<T>> tasks, Consumer<T> consumer) {
    CompletionService<T> completionService = new ExecutorCompletionService<>(EXECUTOR_SERVICE);
    tasks.forEach(completionService::submit);
    tasks.forEach(
        x -> {
          try {
            consumer.accept(completionService.take().get());
          } catch (InterruptedException e) {
            e.printStackTrace();
          } catch (ExecutionException e) {
            e.printStackTrace();
          }
        });
  }

  public static void destroy() {
    System.out.println("摧毁线程池");
    EXECUTOR_SERVICE.shutdown();
  }

  public static void main(String[] args) {
    // 启动3个线程执行试试看
    List<Callable<Integer>> tasks =
        Arrays.asList(
            () -> {
              try {
                TimeUnit.SECONDS.sleep(30);
                System.out.println("task 30 completed");
              } catch (InterruptedException e) {
                e.printStackTrace();
              }
              return 30;
            },
            () -> {
              try {
                TimeUnit.SECONDS.sleep(10);
                System.out.println("task 10 completed");
              } catch (InterruptedException e) {
                e.printStackTrace();
              }
              return 10;
            },
            () -> {
              try {
                TimeUnit.SECONDS.sleep(20);
                System.out.println("task 20 completed");
              } catch (InterruptedException e) {
                e.printStackTrace();
              }
              return 20;
            });

    ThreadPriorityUtil.submit(tasks, x -> System.out.println("回调结果：" + x));

    ThreadUtil.sleep(40000L);
    ThreadPriorityUtil.destroy();
  }
}

执行看看

OK，先执行结束的线程，先消费。

总结

一个姑娘，如果有被人喜欢，而且那个人喜欢的干干净净，怎么都是一件美好的事情。

如果本文对你有帮助的话，不要吝啬你的赞，狠狠的甩给我。

到此这篇关于Java多线程提交按照时间顺序获取线程结果详解流程的文章就介绍到这了,更多相关Java 多线程内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • Java多线程 两阶段终止模式Two-Phase Termination Patter

    目录 1.两阶段终止模式介绍 2.Terminator代码演示 3.TerminationRequester 4.模拟客户端或者服务端都可能终止服务的例子 5.mac telnet模拟客户端输入 1.两阶段终止模式介绍 有时候,我们希望提前结束线程,但安全可靠地停止线程,并不是一件容易的事情,如果立即停止线程,会使共享的数据结构处于不一致的状态,如目前已经废弃使用的Thread类的stop方法(它会使线程在抛出java.lang.ThreadDeath之后终止线程,即使是在执行synchroni

  • java 多线程与并发之volatile详解分析

    java 多线程与并发之volatile详解分析

    目录 CPU.内存.缓存的关系 CPU缓存 什么是CPU缓存 为什么要有多级CPU Cache Java内存模型(Java Memory Model,JMM) JMM导致的并发安全问题 可见性 原子性 有序性 volatile volatile特性 volatile 的实现原理 总结 CPU.内存.缓存的关系 要理解JMM,要先从计算机底层开始,下面是一份大佬的研究报告 计算机在做一些我们平时的基本操作时,需要的响应时间是不一样的!如果我们计算一次a+b所需要的的时间: CPU读取内存获得a,1

  • Java多线程 自定义线程池详情

    主要介绍: 1.任务队列 2.拒绝策略(抛出异常.直接丢弃.阻塞.临时队列) 3.init( min ) 4.active 5.max min<=active<=max package chapter13; import java.util.ArrayList; import java.util.LinkedList; import java.util.List; public class SimpleThreadPool { public final static DiscardPolicy

  • Java 多线程的同步代码块详解

    Java 多线程的同步代码块详解

    目录 synchronized 同步代码块 同步方法(this锁) 静态同步方法 死锁问题 lock 总结 火车站抢票问题 由于现实中买票也不会是零延迟的,为了真实性加入了延迟机制,也就是线程休眠语句 package test.MyThread.ticketDemo; public class RunnableThread implements Runnable{ private int ticket = 100; @Override public void run(){ while(true)

  • Java多线程之Worker Thread模式

    目录 一.Worker Thread模式 二   .Worker Thread模式中的角色 1.Client(委托者) 2.Channel(通信线路) 3.Worker(工人) 4.Request(请求) 三.Worker Thread使用场景 四.Worker Thread模式程序示例 一.Worker Thread模式 Worker的意思是工作的人,在Worker Thread模式中,工人线程Worker thread会逐个取回工作并进行处理,当所有工作全部完成后,工人线程会等待新的工作到来

  • Java中保证线程顺序执行的操作代码

    只要了解过多线程,我们就知道线程开始的顺序跟执行的顺序是不一样的.如果只是创建三个线程然后执行,最后的执行顺序是不可预期的.这是因为在创建完线程之后,线程执行的开始时间取决于CPU何时分配时间片,线程可以看成是相对于的主线程的一个异步操作. public class FIFOThreadExample { public synchronized static void foo(String name) { System.out.print(name); } public static void

  • Java多线程提交按照时间顺序获取线程结果详解流程

    Java多线程提交按照时间顺序获取线程结果详解流程

    Maven依赖 其实要不要无所谓.主要是为了方便. <dependency> <groupId>cn.hutool</groupId> <artifactId>hutool-all</artifactId> <version>5.7.15</version> </dependency> 代码 不废话,上代码. package com.hy.csdn.tools; import cn.hutool.core.th

  • Java Mybatis框架增删查改与核心配置详解流程与用法

    Java Mybatis框架增删查改与核心配置详解流程与用法

    目录 Mybatis简介 Mybatis开发步骤: Mybatis的映射文件概述 Mybatis的增删改查操作 MyBatis的核心配置文件概述 MyBatis核心配置文件层级关系 MyBatis常用配置解析 Mybatis相应API 原始JDBC操作 原始jdbc操作(查询数据) 原始jdbc操作(插入数据) 原始jdbc操作的分析原始jdbc开发存在的问题如下: ①数据库连接创建.释放频繁造成系统资源浪费从而影响系统性能 ②sql 语句在代码中硬编码,造成代码不易维护,实际应用sql变化的可

  • Python获取网页数据详解流程

    Python获取网页数据详解流程

    Requests 库是 Python 中发起 HTTP 请求的库,使用非常方便简单. 发送 GET 请求 当我们用浏览器打开东旭蓝天股票首页时,发送的最原始的请求就是 GET 请求,并传入url参数. import requests url='http://push2his.eastmoney.com/api/qt/stock/fflow/daykline/get' 用Python requests库的get函数得到数据并设置requests的请求头. header={ 'User-Agent'

  • Java Fluent Mybatis 分页查询与sql日志输出详解流程篇

    Java Fluent Mybatis 分页查询与sql日志输出详解流程篇

    目录 前言 准备数据 Sql日志配置 官方分页查询 PageHelper分页查询 总结 前言 接着我上一章:Java Fluent Mybatis 项目工程化与常规操作详解流程篇 下 上一章我把项目做了一部分工程化包装,主要还是想要之后的调试能够方便一些.那么这一章接着上一章的内容,做一下查询分页,并且将每次请求所调用的sql语句写在日志里面,便于我们观察定位问题.代码之后还是会上传到github. GitHub代码仓库地址:GitHub仓库 准备数据 简单的准备了一些数据. Sql日志配置 之

  • Java程序顺序结构中逻辑控制语句详解流程

    Java程序顺序结构中逻辑控制语句详解流程

    目录 一.顺序结构 二.分支结构 1.if语句 2.switch 语句 三. 循环结构 1 .while 循环 2. break 3. continue 4.for循环 5.do while循环 四.输入输出 1.输出到控制台 2 .从键盘输入 五.练习 看前欣赏美图! 上才艺! 目录 一.顺序结构二.分支结构1.if语句2.switch 语句 三. 循环结构1 .while 循环2. break3. continue4.for循环5.do while循环 四.输入输出1.输出到控制台2 .从键

  • Java中该如何优雅的使用线程池详解

    Java中该如何优雅的使用线程池详解

    目录 为什么要用线程池? 线程池 线程池基本概念 线程池接口定义和实现类 ExecutorService ScheduledExecutorService 线程池工具类 newFixedThreadPool(int nThreads) newCachedThreadPool() newSingleThreadExecutor() newScheduledThreadPool(int corePoolSize) 任务线程池执行过程 如何确认合适的线程数量? 线程池的使用分析 合理配置线程池大小 线

  • Java多线程中的wait/notify通信模式实例详解

    Java多线程中的wait/notify通信模式实例详解

    前言 最近在看一些JUC下的源码,更加意识到想要学好Java多线程,基础是关键,比如想要学好ReentranLock源码,就得掌握好AQS源码,而AQS源码中又有很多Java多线程经典的一些应用:再比如看了线程池的核心源码实现,又学到了很多核心实现,其实这些都可以提出来慢慢消化并变成自己的知识点,今天这个Java等待/通知模式其实是Thread.join()实现的关键,还有线程池工作线程中线程跟线程之间的通信的核心所在,故在此为了加深理解,做此记录! 参考资料<Java并发编程艺术>(电子PD

  • iOS中的多线程如何按设定顺序去执行任务详解

    iOS中的多线程如何按设定顺序去执行任务详解

    多线程概述 对于ios系统中的某个App来讲,是单进程多线程方式来工作.一般来说,使用多线程的好处是可以把程序分成相对独立的几个模块,可以有效的防止某个模块堵塞的时候导致整个程序卡死:还有就是提高运行效率,现在CPU都是多核,多个核可以同时跑,可以同时执行多条线程. 经常有这样的需求: 1,有m个网络请求. 2,先并发执行其中n几个. 3,待这n个请求完成之后再执行第n+1个请求. 4然后等 第n+1个请求完成后再并发执行剩下的m-(n+1)个请求. 如果我们用GCD,可以使用dispatcg_

  • Java如何从json字符串中获取某个值详解

    Java如何从json字符串中获取某个值详解

    目录 Java从json串中获取某个值 使用org.json进行解析 使用com.alibaba.fastjson进行解析 总结 Java从json串中获取某个值 java对象是不能直接传输,只有json对象 转成字符串 可以进行传输 故 传输中都是json进行的 接收到json数据之后java在进行解析转换成为字符串.且json适用于很多语言之间的传输 json本质上就是一个map. 对应有两种json进行解析 首先就是先对json的合法性进行验证 是否可以进行解析 点击这里 进行json解析

  • Java多线程中wait、notify、notifyAll使用详解

    基础知识 首先我们需要知道,这几个都是Object对象的方法.换言之,Java中所有的对象都有这些方法. public final native void notify(); public final native void notifyAll(); public final native void wait(long timeout) throws InterruptedException; public final void wait() throws InterruptedExceptio

随机推荐