如何安全向MainThread.BeginInvokeOnMainThread传参？锁内调用困境解析

问题场景 #

编写代码时遇到如下技术问题：

lock (locker )
{
    ...    
    string newLabelText = GetNewText();
    MainThread.BeginInvokeOnMainThread(() =>
    {
        label.Text = newLabelText;
    });
    return;
}

核心问题 #

• newLabelText 存在被主线程委托消费前超出作用域的风险（尽管C#闭包会捕获变量延长其生命周期，但逻辑上存在未同步的执行时序问题）
• 原本需要等待主线程UI更新完成后再返回，但由于处于lock代码块内，无法直接使用await MainThread.InvokeOnMainThreadAsync（易引发锁持有过久或死锁）

解决方案 #

方案1：在锁内使用TaskCompletionSource同步等待

lock (locker)
{
    ...    
    string newLabelText = GetNewText();
    var tcs = new TaskCompletionSource<bool>();
    
    MainThread.BeginInvokeOnMainThread(() =>
    {
        try
        {
            label.Text = newLabelText;
            tcs.SetResult(true);
        }
        catch (Exception ex)
        {
            tcs.SetException(ex);
        }
    });
    
    // 同步等待主线程完成UI更新
    tcs.Task.Wait();
    return;
}

方案2：缩小锁范围，释放锁后再等待主线程执行（推荐）

string newLabelText;
// 锁仅保护需要同步的GetNewText逻辑
lock (locker)
{
    ...    
    newLabelText = GetNewText();
}

// 释放锁后处理主线程更新并等待
var tcs = new TaskCompletionSource<bool>();
MainThread.BeginInvokeOnMainThread(() =>
{
    try
    {
        label.Text = newLabelText;
        tcs.SetResult(true);
    }
    catch (Exception ex)
    {
        tcs.SetException(ex);
    }
});
tcs.Task.Wait();
return;

方案说明 #

• TaskCompletionSource 可以手动控制任务的完成状态，完美替代await实现同步等待逻辑
• 方案2通过缩小锁的范围，避免了锁持有时间过长导致的性能瓶颈，同时消除了潜在的死锁风险
• 在委托内捕获异常并通过SetException传递，确保错误能被等待线程正确处理

内容的提问来源于stack exchange，提问作者BillF