将任务添加到任何异步

Question

我希望收听任务的结果，或者如果没有制作或完成，则暂停。具体来说，我正在使用剧作家，并正在为请求添加一个事件侦听器，并且如果这些请求都不包括我要寻找的内容（甚至创建），则希望超时。下面的示例代码：

我已经尝试调查何时何时，但这需要提前了解任务。还研究了Monitor.tryenter，但不确定如何在生成锁之前获得请求？也许是信号量之类的？

string? result = null;

// Start listening for new pages (ClickAsync below opens in a new page)
context.Page += (_, newPage) =>
{
  // From the new page, start listening for requests that page generates
  newPage.Request += async (_, request) =>
  {
    if (request.Url.Contains("some_identifier"))
    {
      await newPage.GotoAsync(request.Url);
      result = await newPage.InnerTextAsync("body");
      // Do something here? We now have the result we want, stop waiting and return it!
    }
  };
};

await mainPage.Locator("a#somelink").ClickAsync();

// Wait for *up to* 30 seconds here.

return result;

Answer 1

利用我的回答评论中的想法，我能够实现目标。我最终将取消令牌传递给了一个任务。delay（30000，令牌）。然后，如果我获得了想要的数据并设置结果值，我只是取消了令牌。

string? result = null;
var tokenSource = new CancellationTokenSource();
var cancelToken = tokenSource.Token;

// Start listening for new pages (ClickAsync below opens in a new page)
context.Page += (_, newPage) =>
{
  // From the new page, start listening for requests that page generates
  newPage.Request += async (_, request) =>
  {
    if (request.Url.Contains("some_identifier"))
    {
      await newPage.GotoAsync(request.Url);
      result = await newPage.InnerTextAsync("body");
      tokenSource.Cancel(); // <-- Got what we needed, cancel 30 second timer
    }
  };
};

await mainPage.Locator("a#somelink").ClickAsync();

try {
  await Task.Delay(30000, cancelToken); // <-- Timeout after 30 seconds.
}
catch
{
  // Not a fan of tokenSource.Cancel() throwing an exception, but I can deal with it.
}

return result;