PowerShell多线程中如何访问全局静态类成员？

问题原因 #

自定义的SharedData类仅在创建它的主Runspace会话中可用，每个通过[powershell]::Create()创建的子Runspace都是独立的执行环境，默认不会继承主Runspace中的自定义类型定义，因此会抛出The type [SharedData] was not found.异常。

解决方法 #

方法1：在子Runspace脚本块中重新定义类

直接在子Runspace的执行脚本开头重新定义SharedData类，确保每个子Runspace都能识别该类型。注意：每个子Runspace的静态成员是独立的，若需跨Runspace共享静态值，需结合锁或线程安全操作同步状态。

修改后的核心代码片段：

$runspace = [powershell]::Create().AddScript({
    param($lockObject, $resultsQueue)

    # 在子Runspace中重新定义类
    class SharedData {
        static [int]$Counter = 0
    }

    function GetNextJob_Lock {
        param($lockObject, $resultsQueue)

        [System.Threading.Monitor]::Enter($lockObject)
        try {
            if([SharedData]::Counter -eq 0) {
                $resultsQueue.Enqueue("Test only")
                [SharedData]::Counter = 1 # 标记已执行，避免重复操作
            }
        }
        catch {
            $resultsQueue.Enqueue($_.Exception.Message)
        }
        finally {
            [System.Threading.Monitor]::Exit($lockObject)
        }
    }

    $result = GetNextJob_Lock -lockObject $lockObject -resultsQueue $resultsQueue

}).AddArgument($lockObject).AddArgument($resultsQueue)

方法2：使用InitialSessionState预加载类

通过InitialSessionState将类定义注入到每个子Runspace的初始化环境中，确保所有子Runspace启动时就加载该类定义。同样，静态成员默认是Runspace独立的，需同步机制实现跨Runspace共享值。

完整修改后的代码：

Set-StrictMode -Version latest

class SharedData {
    static [int]$Counter = 0
}

# 创建InitialSessionState并注入类定义
$iss = [InitialSessionState]::CreateDefault()
$classDefinition = @"
class SharedData {
    static [int]$Counter = 0
}
"@
$iss.Commands.Add(([System.Management.Automation.Runspaces.SessionStateScriptEntry]::Create($classDefinition)))

$lockObject = [System.Object]::new()
$resultsQueue = [System.Collections.Concurrent.ConcurrentQueue[string]]::new()
$runspaces = @()

# 创建带预加载类的Runspace
for ($i=0; $i -lt 10; $i++) {
    $runspace = [powershell]::Create($iss).AddScript({
        param($lockObject, $resultsQueue)

        function GetNextJob_Lock {
            param($lockObject, $resultsQueue)

            [System.Threading.Monitor]::Enter($lockObject)
            try {
                if([SharedData]::Counter -eq 0) {
                    $resultsQueue.Enqueue("Test only")
                    [SharedData]::Counter = 1
                }
            }
            catch {
                $resultsQueue.Enqueue($_.Exception.Message)
            }
            finally {
                [System.Threading.Monitor]::Exit($lockObject)
            }
        }

        $result = GetNextJob_Lock -lockObject $lockObject -resultsQueue $resultsQueue

    }).AddArgument($lockObject).AddArgument($resultsQueue)
    $runspaces += [PSCustomObject]@{
        Pipe = $runspace
        Handle = $runspace.BeginInvoke()
    }
}

# 等待所有Runspace执行完成
$runspaces | ForEach-Object {
    $_.Pipe.EndInvoke($_.Handle)
    $_.Pipe.Dispose()
}

# 输出结果
$result = $null
while ($resultsQueue.TryDequeue([ref]$result)) {
    Write-Output $result
}

方法3：用线程安全全局变量替代静态类（简化方案）

如果核心需求只是跨Runspace共享一个计数变量，可以直接使用线程安全的全局变量，避免自定义类的加载问题：

修改后的核心逻辑：

# 主Runspace定义全局计数变量
$global:sharedCounter = 0

# 子Runspace中的执行代码
$runspace = [powershell]::Create().AddScript({
    param($lockObject, $resultsQueue)

    function GetNextJob_Lock {
        param($lockObject, $resultsQueue)

        [System.Threading.Monitor]::Enter($lockObject)
        try {
            if($global:sharedCounter -eq 0) {
                $resultsQueue.Enqueue("Test only")
                # 使用Interlocked确保线程安全的增量操作
                [System.Threading.Interlocked]::Increment([ref]$global:sharedCounter)
            }
        }
        catch {
            $resultsQueue.Enqueue($_.Exception.Message)
        }
        finally {
            [System.Threading.Monitor]::Exit($lockObject)
        }
    }

    $result = GetNextJob_Lock -lockObject $lockObject -resultsQueue $resultsQueue

}).AddArgument($lockObject).AddArgument($resultsQueue)

内容的提问来源于stack exchange，提问作者marsh-wiggle