- 综合排序
- 最热优先
- 最新优先
- 来自专栏高性能服务器开发
（一）主线程与工作线程的分工
服务器端为了能流畅处理多个客户端链接，一般在某个线程A里面accept新的客户端连接并生成新连接的socket fd，然后将这些新连接的socketfd给另外开的数个工作线程B1、B2、B3、B4，这些工作线程处理这些新连接上的网络 这里我们将线程A称为主线程，B1、B2、B3、B4等称为工作线程。工作线程的代码框架一般如下： while (! 由于网络IO事件处理一般相对比较慢，如果在线程A里面既处理新连接又处理网络IO，则可能由于线程忙于处理IO事件，而无法及时处理客户端的新连接，这是很不好的。 2. 如此反复，也就是说线程A记录了各个工作线程上的socket fd数量，这样可以最大化地来平衡资源，避免一些工作线程“忙死”，另外一些工作线程“闲死”的现象。 3. 即使工作线程不满载的情况下，也可以让工作线程做其他的事情。比如现在有四个工作线程，但只有三个连接。那么线程B4就可以在handle_other_thing()做一些其他事情。
2.2K90发布于 2018-04-04 - 来自专栏技术杂记
线程（2）
pshared, unsigned int __value) __THROW; __sem 指向信号量结构的一个指针 __pshared 不为0时此信号量在进程间共享，否则只能为当前进程的所有线程共享 __newthread 指向线程标识符的指针 __attr 设置线程属性，一般配置为NULL (*__start_routine) (void *) 线程运行函数的起始地址 __arg 运行函数的参数 with __THROW. */ extern int pthread_join (pthread_t __th, void **__thread_return); 调用它的函数将一直等待到被等待的线程结束为止 ，当函数返回时，被等待线程的资源被收回 __th 被等待的线程标识符 __thread_return 为一个用户定义的指针,它可以用来存储被等待线程的返回值 ---- sem_wait semaphore.h 信号量的值没有更改，-1 被返回，并设置errno 来指明错误 EINVAL sem 不是一个有效的信号量 EOVERFLOW 信号量允许的最大值将要被超过 ---- 总结 以下函数可以进行信号量和线程的创建与控制
45010发布于 2021-09-15 - 来自专栏ClearSeve
MFC 用户线程和工作者线程
用户线程 AfxBeginThread 创建线程 AfxEndThread 结束线程 添加类->父类是CWndThread 在CWndThread::InitInstance()函数中实现窗口 1)定义类 1.定义窗口类对象 2.将窗口对象设置为主窗口 3.显示窗口 CMyDialog Dlg; m_pMainWnd = &Dlg; Dlg.DoModal(); 2)创建用户线程 CuserThread * pThread = (CuserThread*)AfxBeginThread(RUNTIME_CLASS(CuserThread));//创建线程 工作线程 AfxBeginThread 创建线程 AfxEndThread 结束线程 1.定义线程处理函数 函数格式 static UINT Thread(LPVOID pParam);//需要是静态成员函数 2.创建线程 AfxBeginThread (XXX,this); 在线程内使用成员变量的方法:(将pParam强转成类地址) XXXClasName* pThis = (XXXClasName*)pParam;
53120编辑于 2022-02-10 - 来自专栏程序员互动联盟
【线程池】线程池与工作队列
AWT 和 Swing 就使用这个模型，在这个模型中有一个 GUI 事件线程，导致用户界面发生变化的所有工作都必须在该线程中执行。 因此，Swing 应用程序经常需要额外的工作线程，用于运行时间很长的、同 UI 有关的任务。 每个任务对应一个线程方法和单个后台线程（single-background-thread）方法在某些情形下都工作得非常理想。每个任务一个线程方法在只有少量运行时间很长的任务时工作得十分好。 而只要调度可预见性不是很重要，则单个后台线程方法就工作得十分好，如低优先级后台任务就是这种情况。 我们通常想要的是同一组固定的工作线程相结合的工作队列，它使用 wait() 和 notify() 来通知等待线程新的工作已经到达了。该工作队列通常被实现成具有相关监视器对象的某种链表。
1.3K80发布于 2018-03-16 - 来自专栏java学习java
异步模式之工作线程
定义 让有限的工作线程（Worker Thread）来轮流异步处理无限多的任务。也可以将其归类为分工模式，它的典型实现 就是线程池，也体现了经典设计模式中的享元模式。 饥饿 固定大小线程池会有饥饿现象 两个工人是同一个线程池中的两个线程 他们要做的事情是：为客人点餐和到后厨做菜，这是两个阶段的工作 客人点餐：必须先点完餐，等菜做好，上菜，在此期间处理点餐的工人必须等待 上菜宫保鸡丁2 上菜宫保鸡丁1 如果修改核心线程为3，即修改代码中 ExecutorService executorService = Executors.newFixedThreadPool( 上菜宫保鸡丁2 上菜宫保鸡丁1 解决方法可以增加线程池的大小，不过不是根本解决方案，还是前面提到的，不同的任务类型，采用不同的线程池，例如： public class Test { public 上菜宫保鸡丁2 创建多少线程池合适 线程池的大小应根据具体的应用场景和系统需求来确定。以下是一些建议供参考： 考虑系统资源：线程池的大小应该与系统可用的资源相匹配。
49430编辑于 2023-10-15 - 来自专栏码匠的流水账
线程池工作窃取实例
序 本文主要来展示一下简版的work stealing线程池的实现。 () { int nCPU = Runtime.getRuntime().availableProcessors(); int queueCount = nCPU / 2 { int nCPU = Runtime.getRuntime().availableProcessors(); int consumerCount = nCPU / 2 .start(); } Thread.sleep(30*1000); stop(); } } 输出 {0=660972, 1=660613, 2=
1.1K10发布于 2018-09-17 - 来自专栏全栈程序员必看
Windows线程漫谈界面线程和工作者线程
线程分为界面线程和工作者线程，界面实际就是一个线程画出来的东西，这个线程维护一个“消息队列”，“消息队列”也是界面线程和工作者线程的最大区别，这个词应该进到你的脑子里，根深蒂固的！ pDlg->m_csForVec.Unlock(); Sleep(10); } return 0; } DWORD WINAPI CTestThreadDlg::Thread2( ，加上下面这句 RunOnceEnd(); } 然后我们之前的两个线程的使用就变成了下面的形式： CMyThread1 g_t1, g_t2, g_t3; void CTestThreadDlg::OnButton3 () { g_t1.Start(this); g_t2.Start(this); g_t3.Start(this); } void CTestThreadDlg::OnButton4() { g_t1.End(); g_t2.End(); g_t3.End(); } 只需要以下几步： 1、派生自己的线程类 2、重载Run函数 3、调用Start启动线程 4、调用End结束线程 当然这种封装方式是我自己喜欢的
91120编辑于 2022-07-15 - 来自专栏Android知识点总结
线程篇2：
Thread ~ thread.start期间 2.Runnable： 可执行态: 可被CPU调度执行期间。 |---等待阻塞:通过调用线程的wait()方法，让线程等待某工作的完成。 结果分析：注02:29代表当前时刻的分秒，即2分29秒 ---->[运行结果]---------------------- 02:29:小汽车开始启动,在路上跑 02:29:小汽车跑到终点 02:31: :53:小汽车跑到终点 3.当加锁睡眠时 在线程1中加synchronized(这里锁用sdf对象,你也可以任意) public class Main2 { static SimpleDateFormat 五、小结 1.需要补充的点: 1.关于synchronized锁这里不展开 2.关于synchronized锁对象需要一致,否则锁不住，然并卵。
54420发布于 2020-04-30 - 来自专栏Java实战博客
多线程2
pool-2-thread-3 当前线程名称pool-2-thread-4 当前线程名称pool-2-thread-6 当前线程名称pool-2-thread-5 当前线程名称pool-2-thread -7 当前线程名称pool-2-thread-8 当前线程名称pool-2-thread-10 当前线程名称pool-2-thread-9 ... 为什么阿里巴巴开发手册抵触使用Java自带线程池 上面分析了3种Java自带的线程池的效率，发现差距就差距在同时工作的线程数。线程数是CPU的压力。 当前线程名称pool-2-thread-1 当前线程名称pool-2-thread-2 ...... 当前线程名称pool-2-thread-7 当前线程名称pool-2-thread-8 当前线程名称pool-2-thread-10 当前线程名称pool-2-thread-9 源码分析 ExecutorService
45120编辑于 2022-01-19 - 来自专栏犀利豆的技术空间
线程池 execute() 的工作逻辑
最近在看《Java并发编程的艺术》回顾线程池的原理和参数的时候发现一个问题，如果 corePoolSize = 0 且 阻塞队列是无界的。线程池将如何工作？ 我们先回顾一下书里面描述线程池execute()工作的逻辑： 如果当前运行的线程，少于corePoolSize，则创建一个新的线程来执行任务。 { return c & CAPACITY; } // 根据工作线程数和线程池状态获取 ctl private static int ctlOf(int rs, int wc) 如果线程池处于 Running状态，则检查工作线程（worker）是否为0。如果为0，则创建新的线程来处理任务。如果启动线程数大于maximumPoolSize，任务将被拒绝策略拒绝。 线程池将如何工作？ 这个问题应该就不难回答了。 最后 《Java并发编程的艺术》是一本学习 java 并发编程的好书，在这里推荐给大家。
1.5K20发布于 2018-10-11 - 来自专栏Java3y
线程池是怎样工作的
ctl 的高3位用来表示线程池的状态(runState)，低29位用来表示工作线程的个数(workerCnt)，为什么要用3位来表示线程池的状态呢，原因是线程池一共有5种状态，而2位只能表示出4种情况， 2、核心线程数和最大线程数 现在有了标志工作线程的个数的变量了，那到底该有多少个线程才合适呢？线程多了浪费线程资源，少了又不能发挥线程池的性能。 还是跟工作线程的个数有关，每一个线程在取任务的时候，线程池会比较当前的工作线程个数与核心线程数： 如果工作线程数小于当前的核心线程数，则使用第一种方法取任务，也就是没有超时回收，这时所有的工作线程都是“ 2、创建工作线程 创建工作线程需要做一系列的判断，需要确保当前线程池可以创建新的线程之后，才能创建。 首先，当线程池的状态是 SHUTDOWN 或者 STOP 时，则不能创建新的线程。 3、启动工作线程 当工作线程创建成功后，也就是 Worker 对象已经创建好了，这时就需要启动该工作线程，让线程开始干活了，Worker 对象中关联着一个 Thread，所以要启动工作线程的话，只要通过
61210发布于 2019-08-27 - 来自专栏CodeNone
【多线程】线程池源码（2）
一进来也是一个死循环，可以先聚焦「什么时候会退出循环」，肯定是「不正常的情况」下会退出 当线程池状态不处于RUNNING或者SHUTDOWN的时候，或者是当线程处于SHUTDOWN但是工作队列中没有任务 当wc大于最大线程数并且工作队列为空的时候，或者当wc大于核心线程数并且timedOut为true并且核心队列为空的时候，或者如果设置了allowCoreThreadTimeOut，并且wc > 1或者核心队列为空的时候 除了不正常的情况，接下来就是从工作队列中获取任务，不过是根据timed的来决定是用poll() 还是take() 。 ❞ 到这里，为什么说线程池能够节省资源呢，是因为其实它创建的线程的消耗只是体现在了Worker类的创建中，把其它要完成的任务放在工作队列里面，然后getTask() 获取任务，最后执行任务（调用task.run ThreadPoolExecutor executor) { System.out.println("task is rejected"); } } 该说的方法也基本都说了，用到的工作队列
37030发布于 2021-08-10 NodeJS工作线程Worker使用简介
NodeJs为异步单线程模型，其中如果主线程如果执行比较耗CPU的操作，可能会失去响应，因此工作线程（Worker）对于执行 CPU 密集型 JavaScript 操作非常有用。 worker_threads模块允许使用并行执行 JavaScript 的线程。模块包含跟worker线程通信的接口。 NodeJs Worker使用我们创建2个js文件，分别是main.js和worker.jsmain.js代码如下，main.js向worker传入一个数组，让worker进行排序后返回const { isMainThread) {//在worker线程 //获取host传来的参数 const data = workerData; //进行一些高CPU的操作 //如：排序
1.3K10编辑于 2024-01-18专用工作者线程
该脚本也可以再请求其他脚本，但一个线程总是从一个脚本源开始。创建专用工作者线程创建专用工作者线程最常见的方式是加载 JavaScript 文件。 换句话说，与活动的专用工作者线程关联的 Worker 对象和与终止的专用工作者线程关联的 Worker 对象无法分别。初始化时，虽然工作者线程脚本尚未执行，但可以先把要发送给工作者线程的消息加入队列。 除了路径解析不同，创建子工作者线程与创建普通工作者线程是一样的。子工作者线程的脚本路径根据父工作者线程而不是相对于网页来解析。 ]);// 通过信道实际发送数据channel.port2.onmessage = ({data}) => console.log(data);// 工作者线程通过信道响应channel.port2.postMessage 通过使用特定于任务的线程池，可以分配固定数量的工作者线程，并根据需要为他们提供参数。工作者线程会接收这些参数，执行耗时的计算，并把结果返回给线程池。然后线程池可以再将其他工作分派给工作者线程去执行。
94410编辑于 2024-08-05- 来自专栏落跑架构师M
java线程池,工作窃取算法
这边会用“工作者”来代替线程的说法，如果在java中这个工作者就是线程。 工作窃取核心思想是，自己的活干完了去看看别人有没有没干完的活，如果有就拿过来帮他干。 我们来看一张图，这张图是发生了工作窃取时的状态。 可以看到工作者B的本地队列中没有了需要执行的规则，它正尝试从工作者A的任务队列中偷取一个任务。 为什么说尝试？ Java中的工作窃取算法线程池 在Java 1.7新增了一个ForkJoinPool类，主要是实现了工作窃取算法的线程池，该类在1.8中被优化了，同时1.8在Executors类中还新增了两个newWorkStealingPool 256 使用工作窃取算法的线程池来优化之前的代码 ExecutorService executor = Executors.newWorkStealingPool(8); for (int i = ForkJoinPool中的工作队列，工作窃取都是需要额外管理的，同时也对线程调度和GC带来了压力。 所以ForkJoinPool并不是万能药大家根据具体需要去使用。
99020发布于 2019-12-30 - 来自专栏落跑架构师M
java线程池,工作窃取算法
这边会用“工作者”来代替线程的说法，如果在java中这个工作者就是线程。 工作窃取核心思想是，自己的活干完了去看看别人有没有没干完的活，如果有就拿过来帮他干。 我们来看一张图，这张图是发生了工作窃取时的状态。 可以看到工作者B的本地队列中没有了需要执行的规则，它正尝试从工作者A的任务队列中偷取一个任务。 为什么说尝试？ Java中的工作窃取算法线程池 在Java 1.7新增了一个ForkJoinPool类，主要是实现了工作窃取算法的线程池，该类在1.8中被优化了，同时1.8在Executors类中还新增了两个newWorkStealingPool 256 使用工作窃取算法的线程池来优化之前的代码 ExecutorService executor = Executors.newWorkStealingPool(8); for (int i = ForkJoinPool中的工作队列，工作窃取都是需要额外管理的，同时也对线程调度和GC带来了压力。所以ForkJoinPool并不是万能药大家根据具体需要去使用。
1.1K21发布于 2020-02-11 Electron——如何使用nodejs工作线程
前言 在electron中如何使用nodejs的工作线程,Demo代码 代码 工作线程 // workerThreads.js const { Worker, isMainThread, parentPort { const p = item.trim().split(/\s+/) // p[0] 应用程序名称 p[1] 应用程序PID 断开连接的时候p[2]
63910编辑于 2024-08-15工作线程（耗时操作）与UI线程实现异步更新
工作线程（耗时操作）与UI线程实现异步更新 概述：工作线程A（多任务）执行期间，把单一任务的结果返回到UI线程更新。 实现： 创建基础流程类（两个handler） public abstract class BaseQueueThread { /** * 设置处理线程、ui处理流程，由子类实现 (); msg.what = priority; msg.obj = obj; mWorkHandler.sendMessage(msg);//从工作线程开始 protected void doInUi(Object obj) { mTextView.setText((String)obj); } } 发送工作线程消息 ，关键点要处理好什么时候执行工作线程，什么时候执行UI线程。
17700编辑于 2025-07-18- 来自专栏全栈程序员必看
JUC多线程：线程池的创建及工作原理
1、线程池的主要优势有： （1）降低资源消耗：通过池化技术重复利用已创建的线程，降低线程创建和销毁造成的损耗。 （2）提高响应速度：任务到达时，无需等待线程创建即可立即执行。 （2）maximumPoolSize：线程池中允许的最大线程数。如果当前workQueue满了之后可以创建的最大线程数。 （3）keepAliveTime：空闲线程的存活时间。 三、线程池执行策略： 执行逻辑说明： （1）当客户端提交任务时，线程池先判断核心线程数是否小于corePoolSize，如果是，则创建新的核心线程数运行这个任务； （2）如果正在运行的线程数大于或等于 1、并发高、任务执行时间短：线程数大概和机器的cpu核数相当，可以使得每个线程都在执行任务，减少线程上下文的切换； 2、并发不高、任务执行时间长： （1）IO密集型：因为IO操作并不占用CPU，大部分线程都阻塞 ，故需要多配置线程数，让CPU处理更多的业务； （2）CPU密集型：线程池中的线程数设置得跟CPU核数差不多，减少线程上下文的切换； 3、并发高、业务执行时间长： 解决这种类型任务的关键不在于线程池而在于整体架构的设计
58530编辑于 2022-06-29 - 来自专栏从零学习云计算
Java 多线程学习（2）——停止线程
重新系统的学习一下Java多线程部分。参考书籍为《java多线程编程核心技术》。 在Java中，有以下三种方法可以终止正在运行的线程： 使用退出标志，使线程正常退出，即run方法完成后，线程终止； 使用stop方法，强行终止线程，不推荐使用，可能会产生不可预料的后果； 使用interrupt 方法中断线程。 使用interrupt方法停止线程 interrupt()方法仅仅是在当前线程中打了一个停止标记，并不会真正的停止线程。 判断线程是否是停止状态 Thread.java类中提供了两种方法判断线程是否是停止状态： this.interrupted()：测试当前线程是否已经中断。执行后具有将状态置清除为false的功能。
83630发布于 2019-05-26
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号