Использование неблокирующих задач - PullRequest
Новая
       5

Использование неблокирующих задач

0 голосов
/ 17 ноября 2018

Следующий код возвращает неправильный продукт. Я ожидаю, что мне нужно использовать термин await в моей функции AsyncMultiply, и я попытался добавить его перед всеми строками, но это не сработало. Как я могу исправить код, чтобы задача стала неблокирующей, правильно вычисляемой задачей? 

using System;
using System.Threading;
using System.Threading.Tasks;

namespace NonBlockingTasks
{
    class Program
    {
        static int prod;
        public static void Main(string[] args)
        {
            Task.Run(async () => { await AsyncMultiply(2, 3); });

            for(int i = 0; i < 10; i++) {
                Console.Write(i + " ");
                Thread.Sleep(100);
            }

            Console.WriteLine();
            Console.WriteLine("Prod = " + prod);

            Console.Write("Press any key to continue . . . ");
            Console.ReadKey();
        }

        public static async Task DoSomethingAsync()
        {
          await Task.Delay(100);
        }           

        public static async Task<int> AsyncMultiply(int a, int b)
        {
            Thread.Sleep(2000);
            prod = a * b;
            return prod;
        }
    }
}

1 Ответ

0 голосов
/ 17 ноября 2018

Task.Run возвращает задание, и вы не дожидаетесь его завершения.Если вы используете C # 7.1 (.net 4.7) или более поздней версии, вы можете вызвать ожидающего до самого вызывающего: 

        static int prod;
        public static async Task Main(string[] args)
        {
            Task running  = Task.Run(async () => { await AsyncMultiply(2, 3); });

            for (int i = 0; i < 10; i++)
            {
                Console.Write(i + " ");
                Thread.Sleep(100);
            }

            await running; // Wait for the previously abandoned task to run.


            Console.WriteLine();
            Console.WriteLine("Prod = " + prod);

            Console.Write("Press any key to continue . . . ");
            Console.ReadKey();
        }

        public static async Task DoSomethingAsync()
        {
            await Task.Delay(100);
        }

        public static async Task<int> AsyncMultiply(int a, int b)
        {
            Thread.Sleep(2000);
            prod = a * b;
            return prod;
        }

В противном случае вы можете заморозить текущий поток, ожидая завершения задачи:

        static int prod;
        public static void Main(string[] args)
        {
            Task running  = Task.Run(async () => { await AsyncMultiply(2, 3); });

            for (int i = 0; i < 10; i++)
            {
                Console.Write(i + " ");
                Thread.Sleep(100);
            }

            running.Wait(); // Freeze thread and wait for task.


            Console.WriteLine();
            Console.WriteLine("Prod = " + prod);

            Console.Write("Press any key to continue . . . ");
            Console.ReadKey();
        }

        public static async Task DoSomethingAsync()
        {
            await Task.Delay(100);
        }

        public static async Task<int> AsyncMultiply(int a, int b)
        {
            Thread.Sleep(2000);
            prod = a * b;
            return prod;
        }
...