This commit is contained in:
CortexCore
2023-09-01 14:33:54 +08:00
parent 4fadd3a530
commit 8ef5c7ec0a
451 changed files with 1048940 additions and 2028 deletions

View File

@@ -1,24 +1,38 @@
namespace BITKit
{
/// <summary>
/// 执行接口,发布者下发任务
/// 订阅者,发布者下发任务给支持并优先级最高的订阅者
/// </summary>
/// <typeparam name="T"></typeparam>
public interface IExcutor<T>
public interface TaskSubscriber<in T>
{
/// <summary>
/// 优先级
/// </summary>
int Priority { get; }
/// <summary>
/// 是否支持并执行任务
/// </summary>
/// <param name="value">值</param>
/// <returns>是否支持</returns>
bool TryExecute(T value);
}
/// <summary>
/// 发布接口,向发布者下发任务
/// </summary>
/// <typeparam name="T"></typeparam>
public interface IRequestor<T>
public interface TaskPublisher<in T>
{
/// <summary>
/// 执行任务
/// </summary>
/// <param name="value"></param>
/// <returns></returns>
bool Excute(T value);
bool Execute(T value);
public static TaskPublisher<T> operator+ (TaskPublisher<T> self, TaskSubscriber<T> x)
{
return self;
}
}
}