如何处理第三方代码中的死锁

Question

我们有一个第三方方法Foo，它有时会因为未知原因而陷入死锁。

我们正在执行一个单线程的 tcp-server，每 30 秒调用一次这个方法来检查外部系统是否可用。

为了缓解第三方代码中的死锁问题，我们将 ping 调用放在 Task.Run 中，以便服务器不会死锁。

喜欢

async Task<bool> WrappedFoo()
{
    var timeout = 10000; 

    var task = Task.Run(() => ThirdPartyCode.Foo());
    var delay = Task.Delay(timeout);

    if (delay == await Task.WhenAny(delay, task ))
    {
        return false;
    }
    else
    {
        return await task ;
    }
}

但这（在我们看来）有可能使空闲线程的应用程序匮乏。因为如果调用ThirdPartyCode.Foo 死锁，线程将永远无法从死锁中恢复，如果这种情况经常发生，我们可能会耗尽资源。

是否有一种处理死锁第三方代码的通用方法？

CancellationToken 不起作用，因为第三方 api 不提供任何取消选项。

更新： 手头的方法是从 SAP 提供的 SAPNCO.dll 中建立和测试到 sap-system 的 rfc-connections，因此该方法不是简单的 network-ping。为了避免进一步的误解，我重命名了问题中的方法

Answer 1

是否有一种处理死锁第三方代码的通用方法？

是的，但这并不容易或简单。

行为不端代码的问题在于它不仅会泄漏资源（例如线程），而且还可以无限期地占用重要资源（例如，一些内部“句柄”或“锁”）。

强制回收线程和其他资源的唯一方法是结束进程。该操作系统用于清理行为不端的进程，并且非常擅长。因此，这里的解决方案是启动一个子进程来进行 API 调用。您的主应用程序可以通过重定向 stdin/stdout 与其子进程通信，如果子进程超时，主应用程序可以终止它并重新启动它。

很遗憾，这是取消不可取消代码的唯一可靠方法。

Answer 2

您的代码没有取消被阻止的操作。使用 CancellationTokenSource 并将取消令牌传递给 Task.Run：

var cts=new CancellationTokenSource(timeout);

try
{
    await Task.Run(() => ThirdPartyCode.Ping(),cts.Token);
    return true;
}
catch(TaskCancelledException)
{
    return false;
}

阻塞很可能是由于网络或 DNS 问题造成的，而不是实际的死锁。

这仍然浪费了等待网络操作完成的线程。您可以使用 .NET 自己的 Ping.SendPingAsync 异步 ping 并指定超时：

var ping=new Ping();

var reply=await ping.SendPingAsync(ip,timeout);
return reply.Status==IPStatus.Success;

PingReply 类包含比简单的成功/失败更详细的信息。 Status property 单独区分路由问题、无法到达的目的地、超时等

Answer 3

取消任务是collaborative operation，因为您将CancellationToken 传递给所需的方法，并在外部使用CancellationTokenSource.Cancel：

public void Caller()
{
     try
     {
          CancellationTokenSource cts=new CancellationTokenSource();
          Task longRunning= Task.Run(()=>CancellableThirdParty(cts.Token),cts.Token);
          Thread.Sleep(3000); //or condition /signal
          cts.Cancel();
     }catch(OperationCancelledException ex)
     {
          //treat somehow
     }
    
}
public void CancellableThirdParty(CancellationToken token)
{
    while(true)
    {
        // token.ThrowIfCancellationRequested()  -- if you  don't treat the cancellation here
        if(token.IsCancellationRequested)
        {
           // code to treat the cancellation signal
           //throw new OperationCancelledException($"[Reason]");
        }
    }
}

正如您在上面的代码中看到的，为了取消正在进行的任务，其中运行的方法必须围绕CancellationToken.IsCancellationRequested 标志或简单的CancellationToken.ThrowIfCancellationRequested 方法构建， 这样调用者只需发出CancellationTokenSource.Cancel。

很遗憾，如果第三方代码不是围绕CancellationToken 设计的（它不接受CancellationToken 参数），那么您无能为力。