如何解决不良模式关闭线程追逐（重新）启动线程的问题

Question

奇怪的容错线程模式并及时关闭它们。注意到这种模式在产品中反复出现。

假设您有一个容错进程 - 网络连接 - 还加入 SSL，或 WMI 连接和查询，或数据库连接和查询等。

您的网络客户端连接失败时将等待一段时间（假设 5 分钟），然后然后尝试重新连接。

有时，当这种情况发生时，您可能还想停止网络，这会引入第二个线程，表明它正在停止并执行某些关闭操作。

如果容错进程正在等待，那么很容易通过让它等待另一个线程管理的事件来终止它。

由于 Connect 功能的流程较长/成本高昂，您将如何中途停止它？如何在 Cancel() 调用之后/期间管理 Connect() 中的步骤，目前可以在 Connect 创建过程中调用 Cancel/Cleanup new SslStream 并因此成功完成 Connect 并处于不完整状态 - m_network 设置为新对象。

private TcpClient m_network = new TcpClient();
private ManualResetEvent m_closing = new ManualResetEvent(true);

private void Connect()
{
    try
    {
        m_network.Connect(m_config.Address.Host, m_config.Address.Port);

        SslStream sslStream = new SslStream(m_network.GetStream(), true, ValidateServerCertificate, ClientCertificateSelection );

        X509CertificateCollection clientCertificates = GetClientCertificates();
        sslStream.AuthenticateAsClient(m_config.Address.Host, clientCertificates, SslProtocols.Default, false );

        // do more stuff in a new thread
    }
    catch (System.Exception ex)
    { Reset(); }
}

public void BeginExecution()
{
    ThreadPool.QueueUserWorkItem(delegate
    {
        m_closing.Reset();
        Connect();
    });
}

public void Cancel()
{
    m_closing.Set();
    Cleanup();
}

private void Cleanup()
{
    TcpClient tempClient = m_network;
    m_network = new TcpClient();
    if (tempClient.Connected)
    {
        tempClient.Close();
    }
}

void Reset(){
    if (m_closing.WaitOne(0))
        return;

    Cleanup();

    if (m_closing.WaitOne(TimeSpan.FromSeconds(300)))
        return;

    ThreadPool.QueueUserWorkItem(delegate { Connect(); });
}

使 Connect 锁定或使用本地网络变量违背了试图尽早终止它的目的。

在 Connect 中的每个操作之后继续检查事件然后调用 Cleanup 似乎很难看。

Answer 1

F# 中的异步块或 C# 的异步 CTP 的好处是——您可以外部化取消和超时流程的处理。如果必须的话，您可以使用 TPL 和延续执行类似的操作。