创建多个线程并调用异步方法进行测试

如何解决创建多个线程并调用异步方法进行测试

我想通过多个线程测试异步方法，所以我创建然后调用如下方法：

public async Task Foo()
{ 
    // some aync code here
}

并创建线程：

var tasks = new List<Task>();
      
for (int i = 0; i < 3; i++)
{
    tasks.Add(Task.Run(() => Foo(i.ToString())));
}

await Task.WhenAll(tasks.ToArray());

首先，我想知道这样测试这种方法的正确方法还是我应该做一些不同的事情？

其次，我在一些文章中看到，如果我像下面这样调用 async：

 var t1 = Foo("1");
 var t2 = Foo("2");

 await Task.WhenAll(t1,t2);

然后这些代码将在单独的 Thread 中运行，对于上面的代码，只要我将 Foo("1") 放在 var t1 上，它就会立即在单独的 Thread 和 {{ 1}} 也是，所以如果是真的那么我们可以说上面的代码是一样的吗？ （我的意思是用同样的方式执行）

以上代码有什么区别？ （这些代码在 Asp.net 核心 API 上）

解决方法

直接调用的 Task 只会在以下情况下并发运行：两者都遇到等待，和 ConfigureAwait(false) 被使用，之后它将在单独的线程上运行。 或者如果通过 Task.Run() 或 Task.StartNew()` 调用。

否则它将在调用者的线程上运行。

,

您将 async-await 与多线程混淆了。

对我理解 async-await 有很大帮助的是 this interview with Eric Lippert 他将 async await 与必须做早餐的厨师进行了比较。

如果厨师必须做早餐，他会开始烧水泡茶。他没有等待水烧开，而是将面包插入吐司。他再一次没有等待，而是开始切西红柿。说完，他环顾四周，看看能不能做点别的，而不是漫不经心地等待。只有在他无事可做的时候，他才会无所事事地等待。

因此，只有厨师环顾四周，看看他是否可以做点别的事情，而不是无所事事地等待。

使用异步等待时做了类似的事情。每当您的线程必须等待另一个进程完成时，例如将数据写入文件、从数据库管理系统查询或从 Internet 获取数据，您的线程不会空闲等待，而是继续处理直到他看到等待。线程向上调用调用堆栈查看调用者是否没有等待，并开始处理直到他看到等待。再次向上调用堆栈。等

它不一定是执行语句的同一个线程，它可以是您的程序拥有的线程池中的任何线程。如果您查看线程 ID，您会看到在 await 线程 ID 已更改后：另一个线程继续。然而，这个线程具有相同的“上下文”，这意味着您可以将其视为原始线程：不需要互斥体、临界区、检查 InvokeRequired 等。只要您不启动新线程，该线程在 await 之后，就好像它是原始线程一样。

var taskWriteFile = this.WriteDataToFileAsync("Hello World!");
var taskFetchData = this.FetchFromDataBaseAsync();
...

您的线程开始执行 WriteDataToFile 中的语句，直到它看到等待。预计每个异步方法至少有一个等待。事实上，如果你忘记添加 await，你的编译器会警告你。

当线程看到await时，它不会空闲等待直到数据写入磁盘，它会向上调用堆栈执行下一条语句。这不是等待，所以线程开始从数据库中获取数据，直到它看到等待。然后它向上调用堆栈执行...

注意：这一切都是由一个线程（一个厨师）完成的。

只要代码没有做太多事情，而是主要需要等待其他进程，这就足以让您的 UI 线程保持响应。无需开始新线程。

只有当您的线程必须进行一些冗长的计算时，他才会忙于对操作员的输入做出反应，就像厨师切西红柿一样。如果您想让 UI 线程保持响应，您可以聘请新厨师开始切西红柿：

ICollection<TomatoSlice> Slice(Tomato tomato) {...}

开始对西红柿切片的不同威胁：

Tomato tomato = this.GrabTomato();
var taskSliceTomatos = Task.Run(() => this.Slic(tomato));

在此之后，您的 UI 线程可以自由地做其他事情：

this.DoSomeThingElse();
ICollection<TomatoSlice> tomatoSlices = await taskSliceTomatos;

注意：如果您的线程没有其他事情要做（例如保持 UI 响应），那么启动一个新线程来执行此操作很少是一个好主意。如果你的厨师无事可做，他会无所事事地等待雇来的厨师把西红柿切完。他本可以自己做，而无需聘请厨师。

回到你的问题

Task.Run 后跟 Task.WhenAll 是否相同？

不，您的第二个代码与第一个代码不同，尽管发布条件可能相同。

如果您需要您的线程保持响应并且您预计该任务将花费相当长的时间，您应该只使用 Task.Run。

我应该像这样测试我的代码吗？

没有。您的程序旨在将先决条件转换为后置条件。如果过程被一个线程调用，那么它应该做这个转换。如果一个线程这样做，那么多个线程也会这样做。

在第一个未完成的情况下启动新线程第二次调用同一个过程的唯一原因是，如果您想测试该过程是否是线程安全的。

bool someBool = false;

async Task<bool> DoItAsync()
{
    this.someBool = !this.someBool;
     await Task.Delay(TimeSpan.FromSeconds(1));
    return this.someBool;
}

很明显，这个程序不是线程保存的。如果程序在运行时重新进入，返回值将不是预期的。

不可重入：

this.someBool = false;
bool b1 = await this.DoItAsync();
bool b2 = await this.DoItAsync();
Assert.IsTrue(b1);
Assert.IsFalse(b2);

但是，如果要求该方法是线程保存的，则以下内容足以对其进行测试：

this.someBool = false;
Task<bool> t1 = this.DoItAsync();
Task<bool> t2 = this.DoItAsync();
await Task.WhenAll(new [] {t1,t2});
Assert.IsTrue(t1.Result);
Assert.IsFalse(t2.Result);

通过这种方式，您可以确定 t2 会在 t1 等待时立即执行。如果您使用 Task.Run( () => ...) 启动一个新任务，则无法保证何时启动第二个任务：在第一个任务之前？在第一个任务翻转 someBool 之前或之后？在第一个任务等待之前或之后？我们不知道。