在异步中运行回调函数

Question

我试图了解如何在异步控制台应用程序中运行回调函数。我的基本控制台应用程序代码如下所示：

    using Nito.AsyncEx;

    static void Main(string[] args)

    {

        AsyncContext.Run(() => MainAsync());

    }

    static async Task MainAsync()

    {

    }

我想在异步模式下运行的方法如下来自 websocket api：

using ExchangeSharp;

public static void Main(string[] args)

{

    // create a web socket connection to Binance. Note you can Dispose the socket anytime to shut it down.

    // the web socket will handle disconnects and attempt to re-connect automatically.

    ExchangeBinanceAPI b = new ExchangeBinanceAPI();

    using (var socket = b.GetTickersWebSocket((tickers) =>

    {

        Console.WriteLine("{0} tickers, first: {1}", tickers.Count, tickers.First());

    }))

    {

        Console.WriteLine("Press ENTER to shutdown.");

        Console.ReadLine();

    }

}

上面的代码旨在锁定控制台应用程序并订阅接收数据的事件，并对接收到的数据执行某些操作。

我想要做的是在单独的线程或异步中运行上述内容，以便我可以在 MainAsync() 函数中继续我的代码。

我在这方面的 C# 经验是有限的。将不胜感激任何帮助！

Answer 1

根据源代码 GetTickersWebSocket不是阻塞调用。您发布的唯一阻塞调用是Console.ReadLine。 ExchangeBinanceAPI有它自己的基于回调的异步，所以，只需扔掉Console.ReadLine，或者在它之前放置更多代码：static async Task MainAsync(){    ExchangeBinanceAPI b = new ExchangeBinanceAPI();    using (var socket = b.GetTickersWebSocket((tickers) =>    {        Console.WriteLine("{0} tickers, first: {1}", tickers.Count, tickers.First());    }))    {        // code continues here        Console.WriteLine("Press ENTER to shutdown.");        Console.ReadLine();    }}作为旁注。我对这个项目不熟悉，但源代码显示了里面的穷人的异步性WebSocketWrapper：Task.Factory.StartNew(ListenWorkerThread)// inside ListenWorkerThread_ws.ConnectAsync(_uri, CancellationToken.None).GetAwaiter().GetResult();result = _ws.ReceiveAsync(receiveBuffer, _cancellationToken).GetAwaiter().GetResult();等等。有尝试以同步方式调用异步代码。取而代之的是，至少ListenWorkerThread必须转换为async方法，并且绝对不能通过Task.Factory.StartNew.如果我必须使用这个项目，我会发布一个以真正异步方式重写代码的请求。

Answer 2

如果您直接使用异步方法，则不会阻塞调用者线程，您可以在任何地方调用它，Consolo.ReadLine()然后Task根据需要使用返回来处理结果。public static void Main(string[] args){    // Would not block the thread.    Task t = MainAsync();    // Only if you need. Would not block the thread too.    t.ContinueWith(()=> { code block that will run after MainAsync() });    // create a web socket connection to Binance. Note you can Dispose the socket anytime to shut it down.    // the web socket will handle disconnects and attempt to re-connect automatically.    ExchangeBinanceAPI b = new ExchangeBinanceAPI();    using (var socket = b.GetTickersWebSocket((tickers) =>    {        Console.WriteLine("{0} tickers, first: {1}", tickers.Count, tickers.First());    }))    {        Console.WriteLine("Press ENTER to shutdown.");        Console.ReadLine();    }}