异步操作，我做错了......为什么？ [关闭]

Question

同步代码：

public static void ImportData()
{

    for (var i = 0; i < 40000; i++)
    {
        DoSomething(i)
    }
}

异步代码：

public static void ImportDataAsync()
{
    for (int i = 0; i < 40000; i++)
    {
        await DoSomething(i)
    }
}

为了清楚起见，这是我第一次尝试异步操作。

使用异步代码，我的软件真的很慢，如果我同步运行命令行应用程序的多个实例，速度会快 10 倍。

我的意思是，我不认为 DB 访问和 GetAsync 函数的 try/catch 块会在这两种方法之间造成这种差异，你怎么看？

编辑：我不知道如何改进这个问题，但我会尝试给出答案。

我要问的是“Parallel.Foreach”方法，我正在做的是认为“await”前缀会将当前线程设置为待机创建另一个线程并继续 for 循环，而不是等待什么did 是简单地离开该方法直到等待结果，然后他在 for 循环中的同一点返回并在他等待的地方恢复它。

我只是把事情弄糊涂了，特别是在控制台应用程序中，实际上我没有看到任何使用 await/async 的充分理由。

Answer 1

初读时，可能是这个？ 20 000 与 100 000 次迭代？

// Sync version
var start = 4000000;
var end = start + 20000;

// Async version
var start = 4000000;
var end = start + 100000

在你的异步方法中我也看到了一些东西：

1. public static void ImportAsyncData() 应该是public static async Task ImportAsyncData() 让调用者等待你的操作

2. var slot = gs.GetAsync(c); 我想在这里你想await 进行那个调用：var slot = await gs.GetAsync(c); 这样你就不必使用ContinueWith，因为你的GetAsync 调用正在等待，所以仅当或GetAsync 任务完成时才会执行下一行代码。

3. 你不应该用这样的“忙等待”来等待：while (requestDid - requestDone > 100);，你正在使用你的 CPU 来等待。在这种情况下，您可以在任务之间使用共享变量来考虑并发性，也许使用一些简单的lock 逻辑。

您可以将它重构为这样的东西，但我不太了解您想要实现什么以及您的问题是什么:-)

public async Task ImportAsyncData()
{
    var gs = new Site();

    int requestDid = 0;
    int requestDone = 0;
    var found = 0;

    var watch = System.Diagnostics.Stopwatch.StartNew();
    var start = 4000000;
    var end = start + 100000

    var cod = "user"

    for (int i = start; i < end; i++)
    {
        var ts = watch.Elapsed;
        string elapsedTime = String.Format("{0:00}:{1:00}:{2:00}.{3:00}",
            ts.Hours, ts.Minutes, ts.Seconds, ts.Milliseconds / 10);

        Console.Title = "R: " + (i - start) + " F: " + found + " EL: " + ts;

        var c = cod + i;

        var user = await gs.GetAsync(c);
        if (user == null)
        {
            requestDone++;
            return;
        }

        using (var db = new Database())
        {
            found++;
            db.InsertUser(user);
        }

        requestDid++;
    }
}