如何在C#中用pthread_kill中断线程的阻塞read系统调用？

核心问题点 #

1. 错误使用SIGINT信号：SIGINT属于终端控制信号，默认关联系统级终端行为（如停止输入回显），即便注册了自定义处理函数，仍可能触发终端状态异常，甚至导致进程被系统默认逻辑终止。
2. sigaction结构体定义隐患：手动拆分sa_mask为16个long的方式，可能与目标系统sigset_t的实际内存布局不匹配；sa_restorer字段用Action类型错误，现代系统该字段已废弃，应设为IntPtr.Zero。
3. 未处理read的中断返回值：信号中断阻塞read时，read会返回-1且errno设为EINTR，若未处理该情况，线程无法正确感知中断并退出。

修正步骤 #

1. 改用SIGUSR1替代SIGINT #

SIGUSR1是用户自定义信号，无系统默认终端关联行为，可避免终端异常：

// Linux下SIGUSR1的定义值为10
public const int SIGUSR1 = 10;

2. 修正sigaction_t结构体定义 #

匹配Linux系统sigset_t的实际布局（通常为2个unsigned long），并修正字段类型：

public delegate void SignalHandler(int signal);

[StructLayout(LayoutKind.Sequential)]
public struct sigaction_t
{
    public SignalHandler? sa_handler;
    [MarshalAs(UnmanagedType.ByValArray, SizeConst = 2)]
    public ulong[] sa_mask; // 对应Linux的sigset_t结构
    public int sa_flags;
    public IntPtr sa_restorer; // 现代系统已废弃，设为IntPtr.Zero
}

[DllImport("libc.so.6")]
public static extern int sigaction(int signum, ref sigaction_t act, IntPtr oldact);

3. 正确注册信号处理函数 #

初始化空信号掩码，设置sa_flags为0（不启用SA_RESTART，确保read被信号中断后直接返回）：

NativeMethods.sigaction_t usr1_handler = new();
usr1_handler.sa_handler = (signal) => 
{ 
    Console.WriteLine($"Handler for SIGUSR1 (signal {signal})"); 
};
usr1_handler.sa_mask = new ulong[2]; // 初始化空信号集合
usr1_handler.sa_flags = 0;
usr1_handler.sa_restorer = IntPtr.Zero;

int result = NativeMethods.sigaction(NativeMethods.SIGUSR1, ref usr1_handler, IntPtr.Zero);
if (result != 0)
    throw new Exception($"sigaction failed, errno: {Marshal.GetLastWin32Error()}");

4. 处理read的中断返回值 #

在循环中检查read返回值，捕获EINTR错误并退出线程：

// 定义errno获取方法与EINTR常量
[DllImport("libc.so.6")]
public static extern int errno();

public const int EINTR = 4;

// 线程循环逻辑
while (!cancellationToken.IsCancellationRequested)
{
    int readSize = NativeMethods.read(_fd, buffer, BufferSize);
    if (readSize == -1)
    {
        int err = NativeMethods.errno();
        if (err == EINTR)
        {
            Console.WriteLine("read interrupted by signal");
            break; // 感知到中断，退出循环终止线程
        }
        else
        {
            throw new IOException($"Read failed, errno: {err}");
        }
    }
    // 处理读取到的数据
}

5. 调整pthread_kill发送的信号 #

将取消回调中的SIGINT替换为SIGUSR1：

var monitorThread = NativeMethods.pthread_self();

cancellationToken.Register(
    () =>
    {
        Console.WriteLine("Calling pthread_kill");
        int killResult = NativeMethods.pthread_kill(monitorThread, NativeMethods.SIGUSR1);
        if (killResult != 0)
        {
            Console.WriteLine($"pthread_kill failed, errno: {Marshal.GetLastWin32Error()}");
        }
        Console.WriteLine("pthread_kill finished");
    });

额外注意事项 #

• 确保目标线程未屏蔽SIGUSR1：可通过pthread_sigmask检查或调整线程的信号掩码。
• 若必须使用SIGINT，需在信号处理函数中手动恢复终端设置（如调用tcsetattr恢复输入回显），但优先推荐使用自定义信号。

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