1

async と await を使用しようとしていますが、バックグラウンド プロセスが完了するまで待機しないという問題があります。アプリケーションを同期的に実行しないのはなぜかと疑問に思われるかもしれません。タスクの一部をできるだけ早く終わらせようとしていますが、残りはこの例に示すように待つことができます。助けてくれてありがとう!=)

class Program
{
    static void Main(string[] args)
    {
        Run();
        //Problem or Maybe Not? Needs this 
        //So that my application won't close immediately
        Console.ReadLine();
    }

    private async static void Run()
    {
        Task<bool> TBool = ProcessRecords();

        if (await TBool)
        {
            //Problem #1 This Line Doesn't Show
            Console.WriteLine("End of Code");
            //SHould be safe to close the application by Now
            //But goes through here not waiting for the return
            //of the last process.

            Environment.Exit(0);

            //My temporary solution is to indicate a Task.Delay(80000)
            //to make sure that all the logging in the background
            //are all done. I dont know if there is a function that shows
            //that there are task running on the background or any 
            //other workaroung will help. =) thanks
        }

    }

    private async static Task<bool> ProcessRecords()
    {
        Task newTask = null;
        //Loop through all the records and send
        //all the records to MQ ASAP
        for (int x = 0; x < 10; x++)
        {
            //I wont wait for this Task so
            //I can send the next record
            newTask = SendToMQ(x);
        }
        //I only need to wait for the last Task to
        //indicate that I can exit the system
        //as soon as it finish
        //Problem #2 The Console.WriteLine doesnt show the last record.
        await newTask;
        return true;
    }

    private async static Task SendToMQ(int count)
    {
        //actual sending of message (Important)
        await Task.Delay(1000);
        //Process of Logging Connect to DB etc, (Not so Important, but takes most of the time)
        await LoggingRecord();
        Console.Clear();
        Console.WriteLine("Done Processing  " + count.ToString() + " records");
    }

    //Logging of each record
    private async static Task LoggingRecord()
    {
        await Task.Delay(5000);
        //Problem #3 This Line Doesn't Show
        Console.WriteLine("Last Log Finished");
    }
}
4

1 に答える 1

1

可能な限り、awaitを使用する必要があります。

await Run();

ただし、この場合はできないため、Waitを使用する必要があります

static void Main(string[] args)
{
    Run().Wait();

    //Problem or Maybe Not? Needs this 
    //So that my application won't close immediately
    //Console.ReadLine();
}

// note the return type is Task
private async static Task Run()
{
...
}

ProcessRecords()には、次の行があります-意味がよくわからないため、対処しませんでした。

//Problem #2 The Console.WriteLine doesnt show the last record.

上記は印刷されます

Done Processing  9 records
End of Code
于 2013-01-24T03:36:03.010 に答える