如何终止非托管代码中阻塞的托管线程?

你试过用非阻塞的吗 NamedPipeServerStream.BeginWaitForConnection

using (NamedPipeServerStream stream = ...)
{
    var asyncResult = stream.BeginWaitForConnection(null, null);

    if (asyncResult.AsyncWaitHandle.WaitOne(5000))
    {
        stream.EndWaitForConnection(asyncResult);
        // success
    }
}

您不必使用固定的超时。你可以使用 ManualResetEvent 要指示线程何时应停止等待连接,请执行以下操作:

ManualResetEvent signal = new ManualResetEvent(false);

using (NamedPipeServerStream stream = ...)
{
    var asyncResult = stream.BeginWaitForConnection(_ => signal.Set(), null);

    signal.WaitOne();
    if (asyncResult.IsCompleted)
    {
        stream.EndWaitForConnection(asyncResult);
        // success
    }
}

// in other thread
void cancel_Click(object sender, EventArgs e)
{
    signal.Set();
}

你应该使用 BeginWaitForConnection 相反。

实际上,我使用的解决方案(在我写问题时想到的)是,在中止所有线程之后,为每个线程创建(并立即处理)一个客户机。

  threads.ForEach(thread=> thread.Abort());
  threads.ForEach(thread=>
              {
                   var client = new PipeClient(ServiceName); 
                   client.Connect(); 
                   client.Dispose();
              });

通过连接,它返回到托管代码,并且Abort()启动(线程捕获ThreadAbortException并清除自身)

这不适用于一般情况(即标题中提出的问题),但适用于我。。。