首页
学习
活动
专区
圈层
工具
发布
    • 综合排序
    • 最热优先
    • 最新优先
    时间不限
  • 来自专栏CodeNone

    【多线程线程源码(3

    线程的源码解读就先告一段落了(其实总感觉缺了什么东西,但是又找不到),本篇文章就简单总结下之前讲的流程及一些用法。 ,但是在线程池里面其实是看作一个任务,线程会创建核心线程来执行这个任务(逻辑是这个线程里面的run()方法)。 可以看到有前后置执行策略,也有拒绝策略,以及线程的相关状态等,接下来通过截图仔细看一下 ? 至于线程的状态如下 ? 结语 java多线程中的线程到这就告一段落啦,这些理论只是相对简单的,线程的复杂是涉及到操作系统底层的了,是基本不可能预测到操作系统是要运行哪个线程的,写这些理论知识是在我们可控的层面尽可能多地去理解它 用下面这张图来做个总结叭,「你理想的线程 vs 真正的线程」 ? 图片来自网络,侵删

    47620发布于 2021-08-10
  • 来自专栏java小记

    java多线程学习(3)-线程

    简介 随着并发的增多,创建、销毁线程的动作也随之增多,所以资源的浪费也随之增多,并且线程的数量变大,管理的难度也会随之加大------于是线程小伙伴就出来前言 线程的几个好处 降低资源消耗。 线程是稀缺资源,如果无限制的创建,不仅会消耗系统资源,还会降低系统的稳定性,使用线程可以进行统一的分配,调优和监控。 看到这些好处有点心动,但是我们不仅要知其然还要知其所以然 如何使用线程? ,也叫核心线程,一般活动的线程数量不会超过此参数的大小; maximumPoolSize:当前线程允许创建的最大线程数; keepAliveTime:线程活动保持时间,当线程空闲下来时,控制线程存活的时间 shutdown和shutdownNow shutdown是将线程的状态设置为shutdown状态,但是并不会停止正在工作的线程,shutdownNow将线程的状态设置为stop状态,并且尝试停止正在执行任务的线程 线程执行的原理 线程流程分析 当线程当中有新提交的任务时,判断流程如下: 基本线程是否满了?

    49330发布于 2018-07-25
  • 来自专栏悟空聊架构 | 公众号

    C#多线程之旅(3)——线程

    每一个线程默认会消耗1MB的内存。线程通过分享和回收线程来削减这些开销,允许多线程被应用在一个非常颗粒级的级别而没有性能损失。当充分利用多核系统去执行密集型计算的并行代码时这是非常有用的。 线程也会在线程的总数量上保持一个限制,从而使线程能够更平稳地运行。太多的线程将会造成管理负担和使CPU缓存是小,从而造成操作系统不能运行。一旦一个限制到达,job排队等待直到另外一个完成才开始。 当使用线程时需要注意下面的事情: 你不能设置一个线程的名字,因为设置线程的名字将会使调试更困难(当你在VS线程窗口中调试时,即使你可以附加一个描述)。 Library中的Task类来轻松的进入线程。 三、不用TPL进入到线程 如果你的应用程序是.NET Framework的早期版本(4.0之前的版本),你将不能使用TPL。

    1.5K60发布于 2018-05-18
  • 来自专栏java跬步

    线程-线程源码详解

    ,最左边3位表示线程状态。 ,实现5种线程状态(在左边3位之后加入中画线有助于理解) 11 //111-00000000000000000000000000000,十进制值:-563,870,912 12 //此状态便是线程能够接受的新任务 39 private static int ctlOf(int rs, int wc) { return rs | wc; } 第一处说明,线程状态用高3位表示,其中包括了符号位。 返回false 的可能如下: * 1.线程没有处于RUNNING状态 * 2.线程工程创建新的任务线程失败 * @param firstTask 外部启动线程时需要构造的第一个线程 corePoolSize : maximumPoolSize)) // 最大线程数不能超过2^29,否则影响左边3位的线程状态值 return false;

    2.1K12发布于 2020-02-18
  • 来自专栏java跬步

    线程-线程的好处

    1.线程的好处。 线程使应用能够更加充分合理的协调利用cpu 、内存、网络、i/o等系统资源。 线程的创建需要开辟虚拟机栈,本地方法栈、程序计数器等线程私有的内存空间。 所以需要通过线程协调多个线程,并实现类似主次线程隔离、定时执行、周期执行等任务。线程的作用包括: 利用线程管理并复用线程、控制最大并发数等。 实现任务线程队列缓存策略和拒绝机制。 隔离线程环境。比如,交易服务和搜索服务在同一台服务器上,分别开启两个线程,交易线程的资源消耗明显要大;因此,通过配置独立的线程,将较慢的交易服务与搜索服务隔开,避免个服务线程互相影响。 在了解线程的基本作用后,我们学习一下线程是如何创建线程的。 第3个参数:keepAliveTime 表示线程池中的线程空闲时间,当空闲时间达到KeepAliveTime 值时,线程被销毁,直到剩下corePoolSize 个线程为止,避免浪费内存和句柄资源。

    2K21发布于 2020-02-18
  • 来自专栏韩曙亮的移动开发专栏

    【Android 异步操作】线程 ( 线程作用 | 线程种类 | 线程工作机制 | 线程任务调度源码解析 )

    文章目录 一、线程作用 二、线程种类 三、线程工作机制 四、线程任务调度源码解析 一、线程作用 ---- 线程作用 : ① 避免创建线程 : 避免每次使用线程时 , 都需要 创建线程对象 ; ---- 线程种类 : ① newCachedThreadPool : 可缓存线程 , 如果 线程线程个数已满 , 回收空闲线程 , 如果没有空闲线程 , 此时会创建新线程 ; ② newFixedThreadPool , 非核心线程数就是 MaxSize - CoreSize ; 示例 : 最大线程数 ( MaxSize ) 是 8 个 , 有 3 个核心线程 ( CoreSize ) , 5 个非核心线程 , 任务拒绝后 , 处理善后 ; 四、线程任务调度源码解析 ---- 在 AsyncTask.java 中 , 在静态代码块中 , 自己 自定义创建了线程 , 没有使用上述四种线程 ; 创建线程时传入的参数 * 因此, 我们应该再次检查运行状态, 如果需要, 将任务放回队列中, 或者启动一个新线程. * * 3.

    1.6K00编辑于 2023-03-28
  • 来自专栏韩曙亮的移动开发专栏

    【Android 异步操作】线程 ( 线程简介 | 线程初始化方法 | 线程种类 | AsyncTask 使用线程示例 )

    文章目录 一、线程简介 二、线程初始化方法简介 三、线程使用示例 一、线程简介 ---- 线程一般是实现了 ExecutorService 接口的类 , 一般使用 ThreadPoolExecutor 3 , 非核心线程数 5 ; 线程任务队列 : 当启动一个线程后 , 线程会不停地从该任务队列中取出任务执行 , 启动核心线程 : 如果当前核心线程没有满 , 小于 3 个 , 那么创建核心线程执行该任务 , 启动非核心线程 : 如果当前核心线程已经有 3 个 , 但是 非核心线程没有满 , 小于 5 个 , 那么会创建非核心线程 , 执行该任务 ; 执行者 Executor 执行任务处理 : 如果核心线程数 有 3 个 , 非核心线程数有 5 个 , 最大线程数已满 ; 如果用户再提交任务给线程 , 就会 将任务放入线程任务队列中排队 ; 如果此时任务队列也满了 , 此时就会 抛出异常 ; 开发者应该通过回调处理被拒绝的任务 ; 线程从任务队列取出任务并执行 : 线程数量 C 线程数量 C < 3 : 创建核心线程执行任务 ; 线程数量 3 \leq C < 8

    3.8K01编辑于 2023-03-28
  • 来自专栏Alan的blog

    线程,进程

    concurrent.futures --- 启动并行任务 — Python 3.7.13 文档concurrent.futures 模块提供异步执行可调用对象高层接口异步执行可以由 ThreadPoolExecutor 使用线程或由 **Executor**ThreadPoolExecutor 线程```pythonimport concurrent.futuresimport urllib.requestURLS = ['http exc)) else: print('%r page is %d bytes' % (url, len(data)))```ProcessPoolExecutor 进程使用进程来实现异步执行调用 任何向提交更多工作的尝试, initializer 都将引发一个异常,当前所有等待的工作都会引发一个 BrokenProcessPool。 : if n % 2 == 0: return False sqrt_n = int(math.floor(math.sqrt(n))) for i in range(3,

    1.6K00编辑于 2023-05-04
  • 来自专栏落叶飞翔的蜗牛

    线程(1)——线程的使用

    int corePoolSize = 2; /* 核心线程的最大线程数 */ int maxPoolSize = 4; /* 线程最大空闲时间 */ 不推荐使用Executors的静态方法创建线程 !!! 第2节 ForkJoinPool ---- ForkJoin线程处理无返回值任务。 初始化数组用时:1847192纳秒, 初始化数组总和:493016 线程计算用时:4220889纳秒, 线程执行结果:493016 ? 第3节 两种线程的比较 ---- ThreadPoolExecutor——适用于IO密集型任务 1.HTTP 2.RPC 3.DB 4.Redis 5.MQ 6.ZK ForkJoinPool——

    3.5K11发布于 2021-01-14
  • 来自专栏南桥谈编程

    线程线程的实现 | 日志

    原理 在一个可执行程序内部存在多个线程和一个任务队列。如果任务队列里长时间没有任务,这些线程就会休眠,如果此时来了一个任务,那么线程就会被唤醒。 像这种,提前创建好线程,需要的时候直接使用,我们称之为线程。这种本质上就是一个生产消费模型。 线程实现 //ThreadPool.hpp #pragma once #include<iostream> #include<unistd.h> #include<string> #include< lg.Enable(SCREEN_TYPE);}while(0) #define EnableFile() do{lg.Enable(FILE_TYPE);}while(0) }; 携带日志的线程设计 Task>(); tp->Init(); tp->Start(); int cnt=10; while (cnt) { // 不断地向线程推送任务

    74310编辑于 2024-10-02
  • 来自专栏AI粉嫩特攻队

    线程

    线程 作用: 增加了线程的复用,降低了系统的开销 原理: 每当一个新的任务要执行的时候,系统会创建一个新的线程去执行任务,直到池中的线程数达到了设置的核心线程数,此时当新的任务要执行的时候,如果线程池中有空闲的线程 如果无法将任务加入队列(比如使用的是有界队列),则创建新的线程,如果此时线程数大于等于了线程预设的最大线程数,那么任务将被拒绝。 java.util.concurrent包对线程的支持: ExecutorService ThreadPoolExecutor (ExecutorService的默认实现类) 1、单线程线程实现 Executors.newSingleThreadExecutor 2、固定大小的线程实现 Executors.newFixedThreadPool 3、可缓存的线程实现 Executors.newCachedThreadPool 4、可定时执行任务的无大小限制的线程实现 Executors.newScheduleThreadPool

    1K30发布于 2019-09-10
  • 来自专栏OSChina

    线程

    * * 二、线程的体系结构: * java.util.concurrent.Executor : 负责线程的使用与调度的根接口 * |--**ExecutorService 子接口: 线程的主要接口 * ExecutorService newCachedThreadPool() : 缓存线程线程的数量不固定,可以根据需求自动的更改数量。 * ExecutorService newSingleThreadExecutor() : 创建单个线程。 Executors.newFixedThreadPool(5); ExecutorService pool2 = Executors.newSingleThreadExecutor(); ExecutorService pool3 执行的结果为: " + sum); } //3 创建10个线程 执行线程 //结果 ,每个线程分开操作不需要过多的等待, for (int i = 0; i < 10; i+

    1K10发布于 2019-09-17
  • 来自专栏Android小知识

    线程

    什么是线程线程进行化,调用的时候直接去池里面去取,而不是每次去重新创建,不用的时候放回线程,而不是直接销毁,从而达到复用。 为什么使用线程 ①复用线程,降低创建以及销毁导致的资源消耗。 ③提高线程的可管理性,提升系统稳定性。 ThreadPoolExecutor JDK提供的线程 ThreadPoolExecutor的构造方法有七个参数 int corePoolSize核心线程数 int maximumPoolSize约定的线程最大数量 long keepAliveTime线程空闲的时候存活多久(但会保留核心线程数的线程数量) TimeUnit unit时间单位 BlockingQueue<Runnable>workQueue线程超过核心线程数的部分放到阻塞队列中 DiscardOldestPolicy最早放入的先丢弃 AbortPolicy直接抛出异常,也是默认的策略 CallerRunsPolicy谁提交的谁执行 DiscardPolicy直接丢弃 合理配置线程

    78910发布于 2021-11-24
  • 来自专栏happyJared

    线程

    为什么要用线程? 降低资源消耗。通过重复利用已创建的线程降低创建和销毁造成的消耗; 提高响应速度。当任务到达时,无须等待线程创建完成就能立即执行任务; 提高线程的可管理性。 如果要让线程执行任务,需要实现的 Runnable 接口或 Callable 接口。 如何创建线程 《阿里巴巴Java开发手册》中,强制线程不允许使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式,这样的处理方式更加明确线程的运行规则,规避资源耗尽的风险 若有新的任务被提交到该线程,则任务会被保存在一个任务队列中,待线程空闲时,按先入先出的顺序执行队列中的任务; CachedThreadPool:该方法返回一个可根据实际情况调整线程数量的线程线程线程数量不确定,但若有空闲线程可以复用,则会优先使用可复用的线程;若所有线程均在工作,又有新的任务提交,则会创建新的线程处理任务。所有线程在当前任务执行完毕后,将返回线程进行复用。

    1.1K10发布于 2019-07-10
  • 线程

    Java 线程的作用 现在服务器端的应用程序几乎都采用了“线程”技术,这主要是为了提高系统效率。 线程就是为了尽量减少这种情况的发生。 下面我们来看看怎么用Java实现一个线程。一个比较简单的线程至少应包含线程管理器、工作线程、任务队列、任务接口等部分。 另外,通过适当的调整线程中的线程数目可以防止出现资源不足的情况。 2.线程的组成部分 一个比较简单的线程至少应包含线程管理器、工作线程、任务列队、任务接口等部分。 线程管理器至少有下列功能:创建线程,销毁线程,添加新任务。 工作线程是一个可以循环执行任务的线程,在没有任务时将等待。 3.线程适合应用的场合 当一个服务器接受到大量短小线程的请求时,使用线程技术是非常合适的,它可以大大减少线程的创建和销毁次数,提高服务器的工作效率。

    26710编辑于 2025-08-29
  • 来自专栏java_joseph

    线程

    ,延时功能 jdk8新的线程 workStealingPool 特点:子任务 窃取 这里这样理解,三个线程,各个有自己的队列,他们也有公共的队列, 第一个线程自己创建了3个子任务,执行,另外两个线程会帮线程 "); } } 线程实现源码 上面了解了下线程的使用注意点,现在看下线程怎么实现的 线程的组成部分 线程管理器:创建、管理线程 工作线程:就是线程池中存在的线程 任务队列:这个就是参数里重要之一的工作队列 TERMINATED * When the terminated() hook method has completed * */ //int类型的数字,高3位表示线程状态 command) { if (command == null) throw new NullPointerException(); // 32位,高3位存储线程状态 ,但是,这里指的是永远是数量,HashSet这里并没有区分线程是先创建的还是后创建的, 所以core核心线程数为3,假设有6个,剩下来的3个不一定是最初创建的线程

    1.2K160编辑于 2023-08-08
  • 来自专栏LeetCode

    线程

    ExecutionException, InterruptedException { ExecutorService executor = Executors.newFixedThreadPool(3)

    95800发布于 2019-03-12
  • 来自专栏Java阿呆

    线程

    为什么要用线程? 单线程方式存在以下几个问题: 线程的工作周期:假设线程创建所需时间为T1,线程执行任务所需时间为T2,线程销毁所需的时间为T3,往往是T1+T3大于T2,所以如果频繁的创建线程会损耗过多的额外时间。 线程可以管理和控制线程,因为线程是稀缺资源,如果无限制的创建,不仅会消耗系统资源,还会降低系统的稳定性,使用线程可以进行统一的分配,调优和监控。 线程提供队列,存放缓冲等待执行的任务。 1、任务优先向CorePool中提交,创建核心线程执行任务 2、在CorePool满了之后,任务被提交提交到任务队列,等待线程空闲 3、在任务队列满了之后,但CorePool中还没有空闲线程,那么任务将被提交到 每次提交一个任务就创建一个线程,直到线程达到线程的最大大小。线程的大小一旦达到最大值就会保持不变,如果某个线程因为执行异常而结束,那么线程会补充一个新线程

    83130发布于 2020-11-04
  • 来自专栏网络收集

    线程

    线程基本概念线程线程本质上是一种对象,用于管理线程资源。在任务执行前,需要从线程池中拿出线程来执行。在任务执行完成之后,把线程放回线程。 核心线程(corePool) 通常状况下,线程最多能创建的线程数。当有新任务等待处理时,线程会首先判断核心线程是否已满,如果没满则创建线程执行任务。 即使有其他核心线程空闲也会创建新的核心线程来执行。任务队列(BlockQueue) 线程池中等待被线程执行的任务队列。如果核心线程已满,线程会判断队列是否已满。 最大线程(maximumPool) 任务量很大时,线程最多能创建的线程数。如果队列已满,说明当前任务量已经非常大,仅靠核心线程池内的线程数量已无法处理。 线程会判断最大线程是否已满,如果没满则创建更多线程,从等待队列首部取得任务并执行。拒绝策略(RejectedExecutionHandler) 线程拒绝过量任务的方式。

    71820编辑于 2022-08-07
  • 来自专栏xiaozhangStu

    线程

    基于数组的先进先出队列,此队列创建时必须指定大小; 2)LinkedBlockingQueue      //基于链表的先进先出队列,如果创建时没有指定此队列大小,则默认为Integer.MAX_VALUE; 3) 否则就抛异常,关闭线程,等待任务都执行完,包括队列中的 shutdownNow():关闭线程,不等待任务执行完。 执行该方法,线程的状态立刻变成STOP状态,并试图停止(interrupt()方法)所有正在执行的线程,不再处理还在队列中等待的任务。 ():当前线程池中正在执行任务的线程数量 这个概念? executor = new ThreadPoolExecutor(4, 10, 10, TimeUnit.MINUTES, new LinkedBlockingDeque<>(3),

    92810编辑于 2023-05-04
领券