LuBan.Threading 2026.7.22.1

English | 中文

LuBan.Threading

作者: yswenli | 联系邮箱: yswenli@outlook.com | 代码仓库: https://github.com/yswenli/luban-framework

"多线程不再翻车：锁、池、队列，一行代码搞定并发。"

你是否还在为这些并发问题头疼？

• 命名锁写起来又臭又长，一不小心就死锁？
• 线程池要么手写 Thread[]，要么 Task.Run 满天飞，资源失控？
• 生产者-消费者队列还要自己搞 ManualResetEvent？
• Task 超时、取消、异常捕获，每次都要写一堆样板代码？

如果是，那 LuBan.Threading 就是为你准备的。

它是 .NET 8 下的轻量级多线程工具库，零外部依赖，提供命名锁、线程池、任务池、阻塞队列、Task 扩展等一套完整的并发解决方案。不造框架，只做你手里最顺手的那把扳手。

Related Projects: LuBan.Framework | LuBan.Common

为什么选择 LuBan.Threading？

一分钟预览

using System;
using LuBan.Threading;
using LuBan.Threading.Core;

// 命名锁：按用户ID加锁，using 自动释放
using (await LockerBuilder.Default.GetLockerAsync("user:1001"))
{
    // 同一用户同一时刻只有一个线程能进来
    Console.WriteLine("处理用户 1001 的业务逻辑");
}

// 线程池：固定 4 线程，提交任务并监控
using var pool = new SimpleThreadPool("OrderPool", threadCount: 4);
pool.OnRunning += (s, e) => Console.WriteLine($"[队列:{e.QueeueCount} 运行:{e.RunningCount} 成功:{e.SuccessCount}]");
var taskId = pool.Enqueue(() => Console.WriteLine("处理订单中..."));

// Task 超时控制
var result = await TaskUtil.TimeoutAfterAsync(
    async ct => await FetchDataAsync(ct),
    timeout: TimeSpan.FromSeconds(5),
    cancellationToken: default);

// 阻塞队列：生产者-消费者
var queue = new BlockingQueue<string>();
queue.Enqueue("msg-001");
var msg = queue.Dequeue(maxTimeout: 3000);

没有废话，只有生产力。

技术栈

• 目标框架：.NET 8.0
• 项目类型：类库（Class Library）
• NuGet 包：LuBan.Threading
• 外部依赖：无（零第三方 NuGet 依赖）

安装

dotnet add package LuBan.Threading

工具箱全览

线程工具 — ThreadUtil

命名空间：System

Task 扩展 — TaskUtil

命名空间：System

命名锁 — LockerBuilder

命名空间：LuBan.Threading

LockerReleaser 实现 IDisposable，配合 using 自动释放锁，引用计数归零时自动清理锁池。

线程池 — SimpleThreadPool

命名空间：LuBan.Threading

固定大小的后台线程池，基于 BlockingCollection + Thread[]，适用于对资源上限敏感的场景。

任务池 — SimpleTaskPool

命名空间：LuBan.Threading

基于 ConcurrentQueue + SemaphoreSlim 的异步任务池，适用于大部分耗时小的异步任务。

阻塞队列 — BlockingQueue<T>

命名空间：LuBan.Threading

基于 LinkedList<T> + ManualResetEvent 的线程安全阻塞队列。

实战示例

命名锁：按业务维度加锁

using LuBan.Threading;
using LuBan.Threading.Core;

// 使用全局默认实例
await using var locker = await LockerBuilder.Default.GetLockerAsync("order:10086");
try
{
    // 同一订单号同一时刻只有一个线程能执行
    Console.WriteLine("处理订单 10086...");
}
// locker 离开 using 自动释放

// 同步场景
using (var syncLocker = LockerBuilder.Default.Create("stock:SKU001"))
{
    // 扣减库存
}

// 自定义超时
await using var timedLocker = await LockerBuilder.Default.GetLockerAsync(
    "payment:pay-001",
    timeout: TimeSpan.FromSeconds(5));

线程池：固定线程处理后台任务

using LuBan.Threading;

using var pool = new SimpleThreadPool("NotifyPool", threadCount: 2);

pool.OnRunning += (sender, args) =>
{
    Console.WriteLine($"[{args.Title}] 队列:{args.QueeueCount} 运行:{args.RunningCount} 成功:{args.SuccessCount} 失败:{args.FailCount}");
};

var id1 = pool.Enqueue(() => SendNotification("用户A"));
var id2 = pool.Enqueue(() => SendNotification("用户B"));

// 查询任务状态
var status = pool.GetTaskStatus(id1);  // Pending / Running / Success / Failed

任务池：异步并发限流

using LuBan.Threading;

using var taskPool = new SimpleTaskPool("HttpPool", maxDegreeOfParallelism: 5);

taskPool.OnRunning += (s, e) => Console.WriteLine($"运行中: {e.RunningCount}");

foreach (var url in urls)
{
    taskPool.Enqueue(async () =>
    {
        var html = await httpClient.GetStringAsync(url);
        Console.WriteLine($"已获取: {url}");
    });
}

Task 超时与取消

using System;

// 超时控制：5秒内未完成则抛 TimeoutException
try
{
    var data = await TaskUtil.TimeoutAfterAsync(
        async ct => await FetchRemoteDataAsync(ct),
        timeout: TimeSpan.FromSeconds(5),
        cancellationToken: default);
}
catch (TimeoutException)
{
    Console.WriteLine("请求超时");
}

// 为已有 Task 附加取消
using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(3));
var result = await someTask.WithCancellationAsync(cts.Token);

// 异常降级
var value = await SomeAsyncMethod().Catch(ex =>
{
    Console.WriteLine($"出错了: {ex.Message}");
    return defaultValue;
});

后台轮询

using System;

// 每隔 1 秒轮询一次
await TaskUtil.WhileAsync(() =>
{
    CheckNewMessages();
}, priod: 1000);

// 轮询直到条件满足
await ((Func<bool>)(() =>
{
    return IsServiceReady();
})).Until(milliseconds: 500);

阻塞队列：生产者-消费者

using LuBan.Threading;

var queue = new BlockingQueue<WorkItem>();

// 生产者
queue.Enqueue(new WorkItem { Id = 1, Data = "hello" });

// 消费者（阻塞等待，最多等 10 秒）
var item = queue.Dequeue(maxTimeout: 10_000);
if (item != null)
{
    Process(item);
}

使用小贴士

1. 命名空间别搞错：ThreadUtil 和 TaskUtil 在 System 命名空间；LockerBuilder、SimpleThreadPool、SimpleTaskPool、BlockingQueue<T> 在 LuBan.Threading；LockerReleaser 在 LuBan.Threading.Core。
2. 优先用 LockerBuilder.Default：全局单例，避免重复创建锁池。
3. using 释放锁：LockerReleaser 实现了 IDisposable，务必用 using 包裹，否则锁不会释放。
4. 线程池选型：同步耗时任务用 SimpleThreadPool，异步轻量任务用 SimpleTaskPool。
5. 阻塞队列有超时：Dequeue 默认等 10 秒，按需调整避免线程长时间阻塞。
6. 池记得 Dispose：SimpleThreadPool、SimpleTaskPool、BlockingQueue<T> 都实现了 IDisposable，用 using 包裹确保资源释放。

许可证

MIT License

LuBan.Threading —— 让 .NET 并发编程更简单、更安全、更可控。

如果你也受够了手写线程同步的痛苦，那就把它加进你的工具箱吧。