由调度员派遣的代表绝不会被解雇

Question

我正在尝试触发一个方法作为 NetworkStream 上的异步读取操作的结果。读取操作是通过 BeginRead 和 EndRead 完成的，导致 EndRead 在 BeginRead 指定的回调中被调用。所有非常基本的东西。现在，由于回调是在系统生成的线程中完成的，因此从 NetworkStream 读取的数据不再属于我的线程（称为 BeginRead）。为了克服这个问题，我编写了一个方法来进一步处理读取的数据，我尝试通过线程的调度程序调用该方法。

// These are created in my Thread
private delegate void ReceiverCallback(IPEndPoint sender, byte[] data);
private Dispatcher dispatcher = Dispatcher.CurrentDispatcher;

回调如下所示：

private void DataReceived(IAsyncResult result)
{
    DataReceivedStruct drs = (DataReceivedStruct)result.AsyncState;
    NetworkStream used = drs.stream;
    AutoResetEvent handle = drs.waitHandle;
    used.EndRead(result);
    DispatchRaiseReceived(readBuffer);
    handle.Set();
}

DataReceivedStruct 是一个包含 NetworkStream 和 AutoResetEvent 的简单结构。 ReadBuffer 是一个长度为 1024 的全局私有 byte[]，因为 BeginRead 和 EndRead 不是在同一个方法中调用的。

DispatchRaiseReceive 方法如下所示：

private void DispatchRaiseReceived(byte[] data)
{
    dispatcher.BeginInvoke((ReceiverCallback)RaiseReceived, socket.Client.RemoteEndPoint, data);
}

其中socket 是TcpClient 对象。

调度的方法类似于以下代码。其作用只是通过事件传递数据以进行进一步处理。

private void RaiseReceived(IPEndPoint sender, byte[] data)
{
    if(IsEnabled){
        if (Received != null)
        {
            Received(this, new TCPDataArgs(sender, data));
        }
    }
}

调度程序需要调用的实际方法永远不会被调用。现在，从我在网上找到的情况来看，它可能与未在正确的线程上创建调度程序有关，因此它永远不会在正确的线程上调用该方法。但是，调度程序是在我的线程上创建的，因此不应适用。

Answer 1

为了解决这个问题，我从 UI 线程中显式获取了 Dispatcher，并将其传递到我想要使用它的所需位置。这而不是尝试使用 Dispatcher.CurrentDispatcher 获取它。你知道吗，它成功了。现在可以正确调用代表。

显然 Dispatcher.CurrentDispatcher 没有获得我希望它使用的正确 Dispatcher 。