并行执行同一方法的任务特定段串行及密码复用问题求助

原代码冻结原因 #

你用Invoke时出现冻结，核心问题在于：

• Invoke是同步阻塞式调用，会让当前线程等待UI线程执行完委托逻辑才继续。
• 多个并行任务的Invoke请求会在UI线程的消息队列排队，第一个任务弹出的模态密码框会阻塞UI线程的消息循环，导致后续任务的Invoke请求完全无法被处理，直到对话框关闭——但即使关闭后，后续任务仍会重复执行密码输入逻辑，不符合你的需求。

解决方案 #

我们需要实现「仅第一个任务触发密码输入，其余任务直接复用全局密码」的逻辑，同时避免线程阻塞。核心思路是用信号量控制并发+双重检查锁定，确保密码获取流程的原子性。

步骤1：添加全局控制变量

在类中定义全局的信号量和密码变量（确保线程可见性）：

// 全局密码，volatile确保多线程下的可见性
private static volatile string CPUPassword;
// 信号量，初始计数1，确保同一时间只有一个任务进入密码处理逻辑
private static readonly SemaphoreSlim _passwordSemaphore = new SemaphoreSlim(1, 1);

步骤2：重构密码处理逻辑

把密码验证和输入的逻辑抽成独立方法，用异步方式避免线程阻塞：

private void S7_GetCPU()
{
    // Some Stuff

    // 异步等待密码准备完成
    EnsureCPUPasswordAsync().Wait();

    // 使用全局密码设置CPU
    EncryptedString pwd = new EncryptedString(CPUPassword);
    this.CPU.SetPassword(pwd);

    // More Parallel-Stuff
}

private async Task EnsureCPUPasswordAsync()
{
    // 第一次检查：如果已有密码，直接返回
    if (CPUPassword != null) return;

    // 等待信号量，确保只有一个任务进入后续逻辑
    await _passwordSemaphore.WaitAsync();
    try
    {
        // 第二次检查：防止等待期间其他任务已经获取了密码
        if (CPUPassword != null) return;

        // 在UI线程执行密码输入逻辑（异步调用，避免阻塞线程池）
        await InvokeAsync(() =>
        {
            // 先尝试空密码验证
            EncryptedString tempPwd = new EncryptedString(null);
            this.CPU.SetPassword(tempPwd);
            
            // 如果密码无效，弹出输入框
            if (!this.CPU.PasswordValid)
            {
                CPUPassword = ((MainForm)mainform).ShowInputMessage("Enter Password for CPU", true);
                tempPwd = new EncryptedString(CPUPassword);
                this.CPU.SetPassword(tempPwd);
            }
            else
            {
                // 无需密码时标记为空字符串
                CPUPassword = string.Empty;
            }
        });
    }
    finally
    {
        // 无论是否异常，都释放信号量，避免死锁
        _passwordSemaphore.Release();
    }
}

// .NET Framework下替代InvokeAsync的扩展方法（.NET Core/5+可直接用Control.InvokeAsync）
private Task InvokeAsync(Action action)
{
    var tcs = new TaskCompletionSource<bool>();
    BeginInvoke(new Action(() =>
    {
        try
        {
            action();
            tcs.SetResult(true);
        }
        catch (Exception ex)
        {
            tcs.SetException(ex);
        }
    }));
    return tcs.Task;
}

方案核心优势 #

1. 原子性：信号量确保只有第一个任务会触发密码输入，其余任务直接等待密码准备完成。
2. 无阻塞：用WaitAsync和异步UI调用，避免线程池线程被同步阻塞，防止线程饥饿。
3. 线程安全：双重检查锁定+volatile修饰符，确保多线程下密码变量的可见性和正确性。

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