如何从锁定等待中排除超时？ [复制]

Question

我需要为我的函数调用设置超时以向 ui 发送反馈。

Task.Factory.StartNew(() => {

    var task = Task.Factory.StartNew(() => {

        lock(this) {

            // do work
            Thread.Sleep(5000);                
        }
    });

    // if the lock above blocks the thread, this might be timed out

    if(task.Wait(timeout)) {
        // done
    } else {
        // timeout
    }
});

我最初的解决方案是我把锁放在内部任务之外

Task.Factory.StartNew(() => {

    Monitor.Enter(obj);
    var task = Task.Factory.StartNew(() => {


        // do work

        Thread.Sleep(5000);
        Monitor.Exit(obj);                

    });

    // if the lock above blocks the thread, task won't start.

    if(task.Wait(timeout)) {
        // done
    } else {
        // timeout
    }
});

但它不起作用。

我的问题是，如何为我的任务指定超时但排除锁定等待？

Answer 1

您可以使用SemaphoreSlim 进行异步等待。另外，一旦你这样做了，你就不需要外部的Task.Run，但我把它留在里面了。你可以使用Task.Delay而不是Thread.Sleep，因为前者不会阻塞当前线程，异步等待并且可以也可以通过CancellationToken 取消。

private SemaphoreSlim semaphore = new SemaphoreSlim(1,1);

// Add ability to cancel work
public async Task DoWorkAsync(Action work, CancellationToken token)
{
    await Task.Run(async () =>
    {         
        try
        {
            await semaphore.WaitAsync(token);
            await Task.Run(work, token);
        }
        finally     
        {
            semaphore.Release();
        }

        // use await Task.Delay rather than Thread.Sleep as it doesn't use a thread
        // and stops almost immediately when cancellation requested.
        await Task.Delay(5000, token);
    }, token);
}

要创建超时场景，请创建一个带有超时的CancellationTokenSource 并捕获OperationCanceledException 以观察超时。

try
{
    var cts = new CancellationTokenSource(TimeSpan.FromSeconds(2));

    await DoWorkAsync(() => /*do work*/, cts.Token);
}
catch(OperationCanceledException ex)
{
    Console.WriteLine("Operation timed out");       
}