Sparkdo.Threading 1.0.3

Sparkdo.Threading

Sparkdo 线程处理库，提供异步计时器、Cron计时器、取消令牌提供者等线程相关的功能。

功能特性

• 异步计时器（AsyncTimer）
• Cron表达式计时器（CronTimer）
• 取消令牌提供者（CancellationTokenProvider）
• 环境数据上下文（EnvironmentDataContext）
• 异步查询执行器（AsyncQueryableExecuter）
• 与 Sparkdo 框架无缝集成

安装

<PackageReference Include="Sparkdo.Threading" Version="x.x.x" />

核心组件

IAsyncTimer

异步计时器接口，继承自 IRunnable 接口：

• Period: 计时器的任务周期（以毫秒为单位）
• Callback: 计时器回调函数
• StartAsync(): 启动计时器
• StopAsync(): 停止计时器

ICronTimer

Cron表达式计时器接口，继承自 IRunnable 接口：

• Callback: 计时器回调函数
• Change(): 更改Cron表达式和初始延迟时间
• StartAsync(): 启动计时器
• StopAsync(): 停止计时器

ICancellationTokenProvider

取消令牌提供者接口：

• CancellationToken: 获取取消令牌
• Use(): 使用指定的取消令牌

IRunnable

可运行接口，定义了启动和停止服务的方法：

• StartAsync(): 启动服务
• StopAsync(): 停止服务

扩展性

该库提供了完整的线程处理功能实现，可以通过以下方式扩展：

1. 实现自定义的 IAsyncTimer 来提供特定的计时器逻辑
2. 实现自定义的 ICronTimer 来提供特定的Cron计时器逻辑
3. 实现自定义的 ICancellationTokenProvider 来提供特定的取消令牌逻辑

代码结构说明

本项目包含以下主要组件：

计时器相关

• IAsyncTimer: 异步计时器接口
• AsyncTimer: 异步计时器实现
• ICronTimer: Cron计时器接口
• CronTimer: Cron计时器实现

取消令牌相关

• ICancellationTokenProvider: 取消令牌提供者接口
• NullCancellationTokenProvider: 空取消令牌提供者实现
• CancellationTokenProviderBase: 取消令牌提供者基类
• CancellationTokenProviderExtensions: 取消令牌提供者扩展方法

环境数据相关

• IEnvironmentDataContext: 环境数据上下文接口
• AsyncLocalEnvironmentDataContext: 基于AsyncLocal的环境数据上下文实现
• IEnvironmentScopeProvider: 环境作用域提供者接口
• EnvironmentDataContextEnvironmentScopeProvider: 环境数据上下文环境作用域提供者实现

配置

• SparkdoThreadingModule: 线程模块配置

所有公共接口和类都添加了详细的 XML 文档注释，便于开发者理解和使用。