SemaphoreSlim 类中的 WaitHandle.WaitOne() 方法无法正常工作

Question

我有一个复杂的情况，但我会尽量缩短它，只知道重要的细节。我正在尝试实现基于任务的作业处理。这是课程：internal class TaskBasedJob : IJob{    public WaitHandle WaitHandle { get; }    public JobStatus Status { get; private set; }    public TaskBasedJob(Func<Task<JobStatus>> action, TimeSpan interval, TimeSpan delay)    {         Status = JobStatus.NotExecuted;        var semaphore = new SemaphoreSlim(0, 1);        WaitHandle = semaphore.AvailableWaitHandle;        _timer = new Timer(async x =>        {            // return to prevent duplicate executions            // Semaphore starts locked so WaitHandle works properly            if (semaphore.CurrentCount == 0 && Status != JobStatus.NotExecuted)            {                return;                Status = JobStatus.Failure;            }            if(Status != JobStatus.NotExecuted)                await semaphore.WaitAsync();            try            {                await action();            }            finally            {                semaphore.Release();            }        }, null, delay, interval);    }}以下是调度程序类：internal class Scheduler : IScheduler{    private readonly ILogger _logger;    private readonly ConcurrentDictionary<string, IJob> _timers = new ConcurrentDictionary<string, IJob>();    public Scheduler(ILogger logger)    {        _logger = logger;    }    public IJob ScheduleAsync(string jobName, Func<Task<JobStatus>> action, TimeSpan interval, TimeSpan delay = default(TimeSpan))    {        if (!_timers.ContainsKey(jobName))        {            lock (_timers)            {                if (!_timers.ContainsKey(jobName))                    _timers.TryAdd(jobName, new TaskBasedJob(jobName, action, interval, delay, _logger));            }        }        return _timers[jobName];    }    public IReadOnlyDictionary<string, IJob> GetJobs()    {        return _timers;    }}在这个库里面，我有一个像下面这样的服务：所以这个服务的想法只是在被调用的字典_accessInfos和它的异步方法中获取一些数据。您可以在构造函数中看到我已经添加了获取数据的作业。

Answer 1

Rajmond 的同事在这里。我弄清楚我们的问题。基本上，等待工作正常等等。我们的问题很简单，如果你这样做，IServiceCollection.BuildServiceProvider()你每次都会得到不同的范围（因此即使使用 Singleton 实例也会创建不同的对象）。试试这个的简单方法：

var serviceProvider1 = services.BuildServiceProvider();

var hashCode1 = serviceProvider1.GetService<IAccessInfoStore>().GetHashCode();

var hashCode2 = serviceProvider1.GetService<IAccessInfoStore>().GetHashCode();

var serviceProvider2 = services.BuildServiceProvider();

var hashCode3 = serviceProvider2.GetService<IAccessInfoStore>().GetHashCode();

var hashCode4 = serviceProvider2.GetService<IAccessInfoStore>().GetHashCode();

hashCode1andhashCode2相同，与hashCode3and相同hashCode4（因为单例），但hashCode1/hashCode2与hashCode3/hashCode4不同（因为不同的服务提供者）。

真正的修复可能是检查 IAccessInfoStore，它会在内部阻塞，直到作业第一次完成。

干杯!