在Linux（WSL Ubuntu）下C# .NET Core 6设置线程亲和性遇段错误

段错误的核心原因 #

你的代码存在两个致命问题导致段错误：

1. 错误的线程ID传递：Thread.CurrentThread.ManagedThreadId是CLR内部的线程标识，并非Linux原生pthread的线程句柄（pthread_t类型）。将该值传入pthread_setaffinity_np会导致内核访问非法内存，直接触发段错误。
2. 错误的CPU集构造：pthread_setaffinity_np要求的第三个参数是cpu_set_t专用结构体，不是简单的ulong类型。cpu_set_t是动态大小的位集合，用来标记允许运行的CPU核心，直接用ulong赋值会破坏结构体格式，引发API调用失败或崩溃。

修正后的Linux下C#代码 #

以下是修复后的代码，通过正确获取原生pthread句柄并构造合法的cpu_set_t来设置线程亲和性：

using System;
using System.Runtime.InteropServices;
using System.Threading;

class Program
{
    // 导入pthread原生API
    [DllImport("libc.so.6", EntryPoint = "pthread_self")]
    private static extern IntPtr pthread_self();

    [DllImport("libc.so.6", EntryPoint = "pthread_setaffinity_np")]
    private static extern int pthread_setaffinity_np(IntPtr thread, ulong cpusetsize, IntPtr cpuset);

    // CPU_SETSIZE通常定义为1024，对应128字节的位集合（1024/8）
    private const int CPU_SETSIZE = 1024;
    private const int CPU_SET_SIZE = CPU_SETSIZE / 8;

    static void Main()
    {
        Thread thread = new Thread(MyThreadFunction);
        thread.Start();
        thread.Join();
    }

    static void MyThreadFunction()
    {
        // 获取当前线程的原生pthread句柄
        IntPtr pthreadHandle = pthread_self();

        // 分配cpu_set_t的内存
        IntPtr cpuSet = Marshal.AllocHGlobal(CPU_SET_SIZE);
        try
        {
            // 初始化cpu_set_t为全0
            Marshal.ZeroMemory(cpuSet, CPU_SET_SIZE);

            // 设置允许运行在CPU 0上：计算位位置并设置对应字节的位
            int cpu = 0;
            int byteIndex = cpu / 8;
            int bitIndex = cpu % 8;
            byte currentByte = Marshal.ReadByte(cpuSet, byteIndex);
            currentByte |= (byte)(1 << bitIndex);
            Marshal.WriteByte(cpuSet, byteIndex, currentByte);

            // 调用设置亲和性的API
            int result = pthread_setaffinity_np(pthreadHandle, (ulong)CPU_SET_SIZE, cpuSet);
            if (result != 0)
            {
                Console.WriteLine($"设置线程亲和性失败，错误码：{result}");
            }
            else
            {
                Console.WriteLine("线程亲和性设置成功，绑定到CPU 0");
            }
        }
        finally
        {
            Marshal.FreeHGlobal(cpuSet);
        }
    }
}

跨平台线程亲和性实现方案 #

要实现真正的跨平台，需针对Windows和Linux分别调用对应的系统API，通过运行时检测操作系统分支处理：

using System;
using System.Runtime.InteropServices;
using System.Threading;
using System.Runtime.Versioning;

class CrossPlatformThreadAffinity
{
    // Linux平台API
    [DllImport("libc.so.6")]
    private static extern IntPtr pthread_self();

    [DllImport("libc.so.6")]
    private static extern int pthread_setaffinity_np(IntPtr thread, ulong cpusetsize, IntPtr cpuset);

    // Windows平台API
    [DllImport("kernel32.dll")]
    private static extern UIntPtr SetThreadAffinityMask(IntPtr hThread, UIntPtr dwThreadAffinityMask);

    [DllImport("kernel32.dll")]
    private static extern IntPtr GetCurrentThread();

    private const int CPU_SETSIZE = 1024;
    private const int CPU_SET_SIZE = CPU_SETSIZE / 8;

    public static bool SetThreadAffinity(int cpuCoreId)
    {
        if (cpuCoreId < 0 || cpuCoreId >= Environment.ProcessorCount)
        {
            Console.WriteLine("无效的CPU核心ID");
            return false;
        }

        if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
        {
            return SetLinuxThreadAffinity(cpuCoreId);
        }
        else if (RuntimeInformation.IsOSPlatform(OSPlatform.Windows))
        {
            return SetWindowsThreadAffinity(cpuCoreId);
        }
        else
        {
            Console.WriteLine("当前平台不支持线程亲和性设置");
            return false;
        }
    }

    private static bool SetLinuxThreadAffinity(int cpuCoreId)
    {
        IntPtr pthreadHandle = pthread_self();
        IntPtr cpuSet = Marshal.AllocHGlobal(CPU_SET_SIZE);
        try
        {
            Marshal.ZeroMemory(cpuSet, CPU_SET_SIZE);
            int byteIndex = cpuCoreId / 8;
            int bitIndex = cpuCoreId % 8;
            byte currentByte = Marshal.ReadByte(cpuSet, byteIndex);
            currentByte |= (byte)(1 << bitIndex);
            Marshal.WriteByte(cpuSet, byteIndex, currentByte);

            int result = pthread_setaffinity_np(pthreadHandle, (ulong)CPU_SET_SIZE, cpuSet);
            return result == 0;
        }
        finally
        {
            Marshal.FreeHGlobal(cpuSet);
        }
    }

    [SupportedOSPlatform("windows")]
    private static bool SetWindowsThreadAffinity(int cpuCoreId)
    {
        IntPtr threadHandle = GetCurrentThread();
        UIntPtr affinityMask = new UIntPtr(1UL << cpuCoreId);
        UIntPtr result = SetThreadAffinityMask(threadHandle, affinityMask);
        return result != UIntPtr.Zero;
    }
}

// 使用示例
class Program
{
    static void Main()
    {
        Thread thread = new Thread(() => {
            bool success = CrossPlatformThreadAffinity.SetThreadAffinity(0);
            Console.WriteLine(success ? "亲和性设置成功" : "亲和性设置失败");
        });
        thread.Start();
        thread.Join();
    }
}

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