C# 暂停线程直到服务器响应

Question

我正在尝试创建一个函数，该函数在被调用时会将信息返回给服务器上的调用者。我在这个函数中想要的是，它创建一个向服务器发出命令的线程，然后将自身挂起，直到服务器返回答案。

public AccountState GetAccount(string key)
{
  AccountState state = null;
  Thread t = new Thread(() =>
  {
    _connection.SomeCommandSentToServer(key);
    accountRequests.TryAdd(key, (Thread.CurrentThread, null));
    //Suspend current thread until ServerReponseHere is called
    Thread.CurrentThread.Suspend();
    //We have been resumed, value should be in accountRequests now
    accountRequests.TryRemove(key, out var item);
    state = item.AccountState;
  });
  t.Start();

  return state;
}


public ConcurrentDictionary<string, (Thread Thread, AccountState AccountState)> accountRequests = new ConcurrentDictionary<string, (Thread Thread, AccountState AccountState)>();

///Once server is done with processed command, call to this function made
public void ServerReponseHere(string key, AccountState state)
{
  accountRequests.TryGetValue(username, out var item);
  accountRequests.TryUpdate(username, (item.Thread, new AccountState()), item);
  item.Thread.Resume();
}

我的想法是，在另一个函数中，当服务器响应时，它会调用上面显示的 ResumeThread 函数。

C# 说 Suspend / Resume 是已弃用的函数，但是 -- 有什么更好的方法来做到这一点？

---

更新

关于“SomeCommandSentToServer”的说明——这只是通过 TCP 套接字向服务器发送命令。

在那个调用中，真正发生的只是传输到服务器。我正在使用一个使用 WinSock2.h 调用“Send()”的库——是的，我知道它是一个已弃用的库……但我正在使用的库需要它。

我有一个单独的线程来轮询来自服务器的输入。所以我没有办法在这个 SomeCommandSentToServer 上“等待”——我需要等待某种回调函数（也就是我提到的恢复函数）——才能完成这项工作。

我不确定该怎么做

Answer 1

有了问题中的所有可用信息，以下是您在使用 async / await 模式时应该达到的目标：

public async Task<AccountState> GetAccountAsync(string key)
{
    // The method SomeCommandSentToServerAsync must be changed to support async.
    AccountState state = await _connection.SomeCommandSentToServerAsync(key);

    return state;
}

您不太可能需要其他任何东西。我的意思是，我的意思是您将不必直接操作线程，将它们放入并发字典中并手动挂起或恢复它们，因为从维护的角度来看它看起来很糟糕；）

.NET 将处理线程部分，这意味着async 基础架构的魔力很可能会释放当前线程（假设实际调用了服务器），直到服务器返回响应。

然后基础架构将使用现有的同步上下文 -例如，如果您在 UI 线程上- 或者从线程池中获取线程 -如果不是-运行该方法的其余部分。

您甚至可以通过简单地返回带有AccountState 类型结果的Task 来进一步减小方法的大小：

public Task<AccountState> GetAccountAsync(string key)
{
    // The method SomeCommandSentToServerAsync must be changed to support async.
    return _connection.SomeCommandSentToServerAsync(key);
}

在这两个示例中，您也必须将调用者设为async：

public async Task TheCallerAsync()
{
    // Grab the key from somewhere.
    string key = ...;

    var accountState = await <inst>.GetAccountAsync(key);

    //  Do something with the state.
    ...
}

将遗留方法转变为异步方法

现在，关于旧的 SomeCommandSentToServer 方法。有一种方法可以等待该遗留方法。是的，您可以将该方法转换为可与async / await 一起使用的异步方法。

当然，我不知道你的实现的所有细节，但我希望你能明白需要做什么。执行此操作的神奇课程称为TaskCompletionSource。

它允许您做的是让您访问Task。您创建该 TaskCompletionSource 类的实例，将其保存在某处，发送命令并立即返回该新实例的 Task 属性。

从轮询线程中获得结果后，您将获取TaskCompletionSource 的实例，获取AccountState 并使用帐户状态调用SetResult。这会将任务标记为已完成并执行您要求的简历部分:)

这是一个想法：

    public Task<AccountState> SomeCommandSentToServerAsync(string key)
    {
        var taskCompletionSource = new TaskCompletionSource<AccountState>();

        //  Find a way to keep the task in some state somewhere
        //  so that you can get it the polling thread.

        //  Do the legacy WinSock Send() command.

        return taskCompletionSource.Task;
    }

    // This would be, I guess, your polling thread.
    // Again, I am sure it is not 100% accurate but 
    // it will hopefully give you an idea of where the key pieces must be.
    private void PollingThread()
    {
         while(must_still_poll)
         {
             //  Waits for some data to be available.

             //  Grabs the data.

             if(this_is_THE_response)
             {
                 // Get the response and built the account state somehow...

                 AccountState accountState = ...

                 // Key piece #1
                 // Grab the TaskCompletionSource instance somewhere.

                 // Key piece #2
                 // This is the magic line:
                 taskCompletionSource.SetResult(accountState);

                 // You can also do the following if something goes wrong:
                 // taskCompletionSource.SetException(new Exception());
             }
         }
    }