在 Task 中引发事件会导致订阅者方法失败

Question

我有一些通过各种事件“链接”的课程。基本上是TCPListener、ClientSession 和Server。

TCPListener 将新连接冒泡到Server，然后Server 创建一个新的ClientSession。

TCPListener 通过事件 ClientConnected 传递新套接字。

引发事件的方法如下所示：

    //Processes a new connection and immediately puts the listen socket back in a receiving state
    private void ProcessAccept(SocketAsyncEventArgs e)
    {
        ClientConnected(this, e));            

        StartAccept();
    }

我想避免做任何可能阻止或减慢接受新客户的事情，所以我努力通过任务来引发事件。这样做的原因是用户可以覆盖Server 中的OnClientConnected 方法，使其长时间运行并可能影响服务器性能。

这是修改后的方法：

    //Processes a new connection and immediately puts the listen socket back in a receiving state
    private void ProcessAccept(SocketAsyncEventArgs e)
    {
        Task.Run(() => ClientConnected(this, e));            

        StartAccept();
    }

使用新方法运行程序时，没有异常崩溃，但服务器无法接收或发送给客户端。

这是Server中的OnClientConnected方法：

    /// <summary>
    /// An event that is fired when a client connects.
    /// </summary>
    /// <param name="sender">The Listener that accepted the connection</param>
    /// <param name="e">The SocketAsyncEventArgs </param>
    protected virtual void OnClientConnected(object sender, EventArgs e)
    {
        ClientSession Session = ClientSessionPool.Pop();

        Session.Socket = ((SocketAsyncEventArgs)e).AcceptSocket;

        string WelcomeMessage = "Connected";

        Session.SendAsync(Encoding.Default.GetBytes(WelcomeMessage));

        this.ClientSessions.Add(Session);

        Console.Write($"\rConnected clients:{ClientSessions.Count}");
    }

只需恢复到旧的同步方法就可以了。

困扰我的是，无论是否使用Task，通过事件传递的SocketAsyncEventArgs 似乎都是正确的，这是我能想到的唯一故障点。

使用Task 版本的方法时，SocketAsyncEventArgs 似乎完全错误。

我怀疑是我对分配给新线程的堆栈的理解导致了我的困惑。谁能看出我的逻辑有漏洞？谢谢！

附言

我知道我当前对ClientSessions 列表的实现不是线程安全的，但在我的测试中，我一次只连接一个客户端。我会最终解决这个问题。

PPS 以下是StartAccept 方法，以防万一有用：

    //Puts the accepting TCP socket back into an accepting state
    public void StartAccept()
    {
        // socket must be cleared since the context object is being reused
        m_SocketEventArgs.AcceptSocket = null;

        bool willRaiseEvent = m_Socket.AcceptAsync(m_SocketEventArgs);
        if (!willRaiseEvent)
        {
            ProcessAccept(m_SocketEventArgs);
        }
    }

Answer 1

解决方案是在 UI 线程上引发您的事件，但异步运行您的事件处理。

private async void OnClientConnected(object sender, EventArgs e)
{
    await Task.Run(() => HandleClientConnected(object, e));
}

protected abstract Task HandleClientConnected(object sender, EventArgs e);