Anduin Xue
Anduin Xue

Anduin's Tech Blog

Async

22
DEC

C# run tasks in a threads pool with fixed size

在本文中，我们将探讨如何在C#中使用固定大小的线程池运行任务。首先，我们提供了一个`CannonQueue`类，该类使用`SafeQueue`来存储待处理的任务，并使用`RunTasksInQueue`方法来并行执行这些任务。为了能够动态地向任务池中添加任务，我们修改了`QueueNew`方法，使其在添加任务时重新启动引擎。同时，我们还提供了一个`QueueWithDependency`方法，以便在需要访问诸如数据库或HTTP之类的依赖项时保持依赖项处于活动状态。 最后，我们展示了如何注册`CannonQueue`作为单例依赖项，并如何在实际应用中使用该服务。例如，我们可以使用`QueueNew`方法将下载任务添加到队列中，并利用`RunTasksInQueue`方法并行执行这些任务。此外，我们还可以使用`QueueWithDependency`方法来处理具有依赖关系的任务，例如使用Entity Framework的任务。 那么，如何在实际应用场景中高效地利用这个线程池呢？本文提供的方法是否足够满足您的需求，还是需要进一步优化？在实际开发过程中，可能会遇到哪些挑战和问题？希望这篇文章能够启发您的思考，帮助您找到解决方案。--GPT 4

C# Async Task Multi-Threading
14
OCT

Fire and forget in ASP.NET Core with dependency alive

在C#中，实现fire and forget非常简单，只需使用Task.Run(() => FireAway())。然而，在ASP.NET Core控制器中，这种方法可能并不合适。当我们在控制器中触发一个耗时的任务，任务将作为fire-and-forget成功启动。但在处理HTTP响应后，控制器可能会被释放，这意味着依赖项可能不再存在，因此任务可能无法完成。 为了在触发任务时始终保持依赖项处于活动状态，我们需要创建一个新的服务来包含它，这个新服务必须是单例的，因为单例服务永远不会被释放。我们需要在服务中获取依赖项，而不是在控制器中，因为控制器的生命周期依赖于HTTP上下文，而单例服务则不依赖。 创建一个新类CannonService，并在StartUp.cs的ConfigureServices方法中将其注册为单例。在控制器中使用时，只需将CannonService注入到控制器中，然后调用一个依赖于某些耗时操作的函数。这个方法不会阻塞当前线程，可以直接向客户端返回结果，而发送器在发送邮件时始终保持活动状态。 作者已将上述代码发布为一个Nuget包。你可以在这里查看源代码：[Aiursoft.Canon](https://gitlab.aiursoft.cn/aiursoft/canon/-/tree/master)，也可以在这里下载包：[Nuget.org](https://www.nuget.org/packages/Aiursoft.Canon/)。 这篇博客分享了在ASP.NET Core中实现fire and forget的方法，以及如何确保依赖项在任务执行过程中保持活动状态。那么，你是否考虑过在自己的项目中使用这种方法来优化性能呢？--GPT 4

ASP.NET Core C# Async Fire and forget
12
DEC

How to run async method in C# synchronous method

在某些情况下，我们可能需要运行一个异步方法并获取其结果，但无法使用`await`关键字，例如在构造函数方法、实现接口同步方法或实现抽象类同步方法中。本文提供了一种解决方案，将异步方法解包并在同步方法中调用。 首先，将以下代码放在任意位置： ```csharp using System.Threading; using System.Threading.Tasks; public static class AsyncHelper { private static readonly TaskFactory _taskFactory = new TaskFactory(CancellationToken.None, TaskCreationOptions.None, TaskContinuationOptions.None, TaskScheduler.Default); public static TResult RunSync<TResult>(Func<Task<TResult>> func) => _taskFactory .StartNew(func) .Unwrap() .GetAwaiter() .GetResult(); public static void RunSync(Func<Task> func) => _taskFactory .StartNew(func) .Unwrap() .GetAwaiter() .GetResult(); } ``` 然后创建一个异步方法，如下所示： ```csharp private static async Task<int> MyAsyncMethod() { // do something async. await Task.Delay(1000); Console.WriteLine("R...--GPT 4

C# .NET Core Async
  • 1