讲师中心 微信公众号

工具推荐

视频效率加速
Seko
Seko

AI短剧一键生成成片

剧云
剧云

中文短剧剧本制作平台

updream

一键生成高质量推广成片

立刻MV
立刻MV

低成本歌曲 MV、视频生成

如何在 Python 中实现每个进程绑定多个 CPU 核心的多进程并行计算

千晨大大_2139

千晨大大_2139

发布时间:2026-01-16 20:58:03

|

352人浏览过

|

来源于php中文网

原创

如何在 Python 中实现每个进程绑定多个 CPU 核心的多进程并行计算

python 的 `multiprocessing.pool` 本身不支持“每进程分配 n 个核心”的语义,但可通过合理设置进程数、结合 `psutil` 或 `os.sched_setaffinity` 实现核心资源的逻辑隔离与高效复用。

在实际高性能计算或 CPU 密集型任务中,开发者有时希望每个子进程独占固定数量的 CPU 核心(例如:2 核/进程),以避免线程争抢、缓存抖动或 NUMA 不均衡等问题。然而,标准 multiprocessing.Pool 的构造参数 processes= 仅指定并发进程数,而非底层 CPU 资源配额——操作系统调度器仍可能将多个进程调度到同一组核心上,无法保证严格的资源隔离。

✅ 正确思路是:将“N 核/进程”转化为“总核数 ÷ N 核/进程 = 最大安全进程数”,再配合 CPU 亲和性(CPU affinity)进行显式绑定。

例如,若系统有 TOTAL_CORES = 16,要求每个工作进程独占 N_CORES_PER_PROCESS = 2 核,且需为父进程预留 2 核,则最大可用工作进程数为:

Linux Omniscient
Linux Omniscient

>全知全能技能Linux版。

下载
import os
TOTAL_CORES = os.cpu_count() or 16
N_CORES_PER_PROCESS = 2
RESERVED_CORES = 2  # 父进程及系统开销预留
MAX_PROCESSES = max(1, (TOTAL_CORES - RESERVED_CORES) // N_CORES_PER_PROCESS)

with multiprocessing.Pool(processes=MAX_PROCESSES) as pool:
    results = pool.map(func, range(10000))

⚠️ 但仅控制进程数还不够——为真正实现“每进程绑定特定核心”,推荐在子进程中调用 os.sched_setaffinity()(Linux/macOS)或使用 psutil.Process().cpu_affinity()(跨平台):

立即学习“Python免费学习笔记(深入)”;

import multiprocessing
import os
import psutil

def worker_init(core_ids):
    """子进程初始化:绑定指定 CPU 核心列表"""
    try:
        psutil.Process().cpu_affinity(core_ids)
    except (psutil.AccessDenied, AttributeError, OSError):
        # Windows 不支持 cpu_affinity;或权限不足时降级处理
        pass

def func(x):
    return x ** 2

if __name__ == "__main__":
    TOTAL_CORES = os.cpu_count()
    N_CORES_PER_PROCESS = 2
    # 划分核心组:[[0,1], [2,3], ..., [8,9]](假设 TOTAL_CORES >= 10)
    core_groups = [list(range(i, min(i + N_CORES_PER_PROCESS, TOTAL_CORES)))
                   for i in range(0, TOTAL_CORES, N_CORES_PER_PROCESS)]

    # 启动 Pool,每个进程初始化时绑定一组核心
    with multiprocessing.Pool(
        processes=len(core_groups),
        initializer=worker_init,
        initargs=(core_groups[0],)  # 注意:此处需动态传入每组核心 —— 实际需用更灵活方式(见下文)
    ) as pool:
        # ⚠️ 上述 initargs 是静态的;如需每进程绑定不同核心组,推荐使用 concurrent.futures + ProcessPoolExecutor 自定义启动逻辑
        pass

? 更健壮的实践方案(推荐):
使用 concurrent.futures.ProcessPoolExecutor 配合自定义 mp_context 和 initializer,或借助第三方库如 loky(joblib 默认后端,支持自动 CPU 分组)或 threadpoolctl 控制底层 BLAS/OpenMP 线程数,避免多层并行嵌套冲突。

? 总结:

  • multiprocessing.Pool 没有 cool_new_pool,但可通过 进程数缩放 + CPU 亲和性绑定 实现等效效果;
  • 核心分配是逻辑策略,非硬性内核限制,需结合 OS 调度特性设计;
  • 生产环境建议搭配 psutil 做运行时核心探测与绑定,并增加异常回退逻辑;
  • 若任务本身含 OpenMP/NumPy 多线程,务必用 threadpoolctl 限制其线程数,防止“每个进程又开 N 线程”,导致超订(oversubscription)。

热门AI工具

更多
二狗PPT
二狗PPT Hot

一款AI演示文稿工具,主要用于专为中式职场打造的AI PPT生成工具,适合需要提升相关任务效率的用户。

PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

音述AI
音述AI Hot

一款AI音频处理工具,主要用于音述AI是一个以“用声音述说故事”为核心的 AI 音乐创作与声音分享社区,适合需要提升相关任务效率的用户。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

码上飞
码上飞 Hot

一款基于自然语言的AI应用开发平台,可根据用户描述自动生成应用程序,帮助个人和团队快速完成应用原型与开发。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

相关专题

更多
线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

4838

2023.08.10

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

1349

2025.12.24

java多线程相关教程合集
java多线程相关教程合集

本专题整合了java多线程相关教程,阅读专题下面的文章了解更多详细内容。

463

2026.01.21

C++多线程相关合集
C++多线程相关合集

本专题整合了C++多线程相关教程,阅读专题下面的的文章了解更多详细内容。

599

2026.01.21

C# 多线程与异步编程
C# 多线程与异步编程

本专题深入讲解 C# 中多线程与异步编程的核心概念与实战技巧,包括线程池管理、Task 类的使用、async/await 异步编程模式、并发控制与线程同步、死锁与竞态条件的解决方案。通过实际项目,帮助开发者掌握 如何在 C# 中构建高并发、低延迟的异步系统,提升应用性能和响应速度。

449

2026.02.06

C++多线程并发控制与线程安全设计实践
C++多线程并发控制与线程安全设计实践

本专题围绕 C++ 在高性能系统开发中的并发控制技术展开,系统讲解多线程编程模型与线程安全设计方法。内容包括互斥锁、读写锁、条件变量、原子操作以及线程池实现机制,同时结合实际案例分析并发竞争、死锁避免与性能优化策略。通过实践讲解,帮助开发者掌握构建稳定高效并发系统的关键技术。

273

2026.03.16

Java 多线程与并发编程实战
Java 多线程与并发编程实战

深入讲解 Java 并发编程体系,涵盖 Thread / Runnable / Callable 线程创建方式、线程生命周期与状态转换、synchronized 同步锁与 Lock/ReentrantLock 显式锁、volatile 可见性保证、ThreadPool 线程池配置与调优(核心参数/拒绝策略)、JUC 并发工具类(CountDownLatch/CyclicBarrier/Semaphore/ConcurrentHashMa

389

2026.04.17

C++ 多线程使用教程大全
C++ 多线程使用教程大全

系统讲解 C++11 及后续标准引入的多线程编程能力,涵盖 std::thread 线程创建与生命周期管理、std::mutex / shared_mutex 互斥锁与读写锁、std::condition_variable 条件变量同步、std::atomic 原子操作与内存序(memory_order)、std::future / promise / async 异步任务、线程池的设计与实现、死锁检测与避免策略,帮助开发者编写正确高效

256

2026.04.28

Go-Zero API开发使用教程
Go-Zero API开发使用教程

本专题聚焦Go-Zero的API开发,拆解.api描述文件的语法结构、路由与分组定义、参数绑定与校验规则,说明统一响应体、JWT鉴权、跨域与接口文档生成的落地方式,并给出网关聚合与接口测试的实践建议。

0

2026.11.12

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Python uv官方安装与入门文档
Python uv官方安装与入门文档

共0课时 | 0人学习

Buffalo框架快速入门指南
Buffalo框架快速入门指南

共0课时 | 0人学习

Valgrind支持平台说明
Valgrind支持平台说明

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn