Julia中如何限制异步函数的并发线程数（已启动16线程）

原生方案：用信号量控制并发数 #

无需额外安装包，借助Julia原生的Base.Semaphore限制同时运行的任务数量，间接控制线程使用数：

# 初始化信号量，允许最多4个并发任务
sem = Base.Semaphore(4)

for name in names
    for age in ages
        Threads.@spawn begin
            # 获取信号量，若已达4个并发则等待
            Base.acquire(sem)
            try
                runtask()  # 执行目标方法
            finally
                # 无论任务成功/失败，都释放信号量
                Base.release(sem)
            end
        end
    end
end

原理：信号量会限制同时进入执行环节的任务数，同一时间最多有4个runtask()在不同线程上运行，从而实现仅用4个线程的效果。

第三方包方案：使用ThreadPools线程池 #

如果需要更完善的线程池管理，可使用ThreadPools包：

1. 先安装包：

] add ThreadPools

2. 固定线程池实现：

using ThreadPools

# 创建固定4个线程的线程池
pool = ThreadPools.FixedThreadPool(4)

for name in names
    for age in ages
        # 将任务提交到指定线程池
        ThreadPools.@tspawnat pool runtask()
    end
end

# 任务完成后关闭线程池
close(pool)

3. 批量任务简化写法：

using ThreadPools

# 直接指定用4个线程批量执行任务
@batch threads=4 for name in names, age in ages
    runtask()
end

注意事项 #

• 原代码中的@async是单线程内的异步任务调度，不涉及多线程，若要控制线程数，重点使用Threads.@spawn或线程池方案。
• 信号量方案适合轻量场景，无需额外依赖；ThreadPools提供更灵活的线程调度策略，适合复杂任务场景。

内容的提问来源于stack exchange，提问作者BAR