小编Den*_*orz的帖子

使用 async/await 时是否需要使字段线程安全?

有时我会遇到访问对象字段的异步/等待代码。例如,无状态项目中的这段代码

private readonly Queue<QueuedTrigger> _eventQueue = new Queue<QueuedTrigger>();
private bool _firing;

async Task InternalFireQueuedAsync(TTrigger trigger, params object[] args)
{
    if (_firing)
    {
        _eventQueue.Enqueue(new QueuedTrigger { Trigger = trigger, Args = args });
        return;
    }

    try
    {
        _firing = true;

        await InternalFireOneAsync(trigger, args).ConfigureAwait(false);

        while (_eventQueue.Count != 0)
        {
            var queuedEvent = _eventQueue.Dequeue();
            await InternalFireOneAsync(queuedEvent.Trigger, queuedEvent.Args).ConfigureAwait(false);
        }
    }
    finally
    {
        _firing = false;
    }
}
Run Code Online (Sandbox Code Playgroud)

如果我理解正确,则await **.ConfigureAwait(false)表明在此之后执行的代码await不一定必须在相同的上下文中执行。所以while这里的循环可以在 ThreadPool 线程上执行。我不明白是什么确保_firing_eventQueue字段同步,例如什么在这里创建锁/内存栅栏/屏障?所以我的问题是;我是否需要使字段线程安全,或者 …

c# multithreading asynchronous task-parallel-library async-await

4
推荐指数
1
解决办法
1万
查看次数