ASP.NETCore中如何将任务添加到后台工作队列并等待结果?
创始人
2024-09-18 15:30:31
0

在ASP.NET Core应用程序中,可以使用IHostedService和BackgroundService类来轻松创建后台服务。我们可以将需要执行的任务包装在一个Task中,并在后台服务中添加到队列中,等待执行完成。

以下是实现此操作的步骤:

首先,定义一个后台服务类,它必须从BackgroundService类继承并且实现ExecuteAsync方法。该方法将在后台运行,并执行我们添加到队列中的任务。

public class WorkerService : BackgroundService
{
    private readonly IBackgroundTaskQueue _taskQueue;
 
    public WorkerService(IBackgroundTaskQueue taskQueue)
    {
        _taskQueue = taskQueue;
    }
 
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            var workItem = await _taskQueue.DequeueAsync(stoppingToken);
 
            try
            {
                //执行我们要添加的任务
                await workItem(stoppingToken);
            }
            catch (Exception ex)
            {
                //处理任务执行过程中出现的异常
            }
        }
    }
}

然后,定义一个队列类,可用于将任务添加到队列并管理它们。该类必须实现IBackgroundTaskQueue接口。

public interface IBackgroundTaskQueue
{
    Task> DequeueAsync(CancellationToken cancellationToken);
 
    void QueueBackgroundWorkItem(Func workItem);
}
 
public class BackgroundTaskQueue : IBackgroundTaskQueue
{
    private ConcurrentQueue> _workItems = new();
    private readonly SemaphoreSlim _signal = new(0);
 
    public async Task> DequeueAsync(CancellationToken cancellationToken)
    {
        await _signal.WaitAsync();
 
        _workItems.TryDequeue(out var workItem);
 
        return workItem;
    }
 
    public void QueueBackgroundWorkItem(Func workItem)
    {
        if (workItem == null)
        {
            throw new ArgumentNullException(nameof(workItem));
        }
 
        _workItems.Enqueue(workItem);
        _signal.Release();
    }
}

然后,我们可以在控制器的Action方法中将任务添加到队列中。

public class HomeController : Controller
{
    private readonly IBackgroundTaskQueue _taskQueue;
 
    public HomeController(IBackgroundTaskQueue taskQueue)
    {
        _taskQueue = taskQueue;
    }
 
    public IActionResult Index()
    {
        _task

相关内容

热门资讯

玩家必备攻略!德州透视hhpo... 玩家必备攻略!德州透视hhpoker,wpk俱乐部是做什么的,真是是真的有挂(有挂秘诀)所有人都在同...
9分钟了解!拱趴大菠萝有什么挂... 9分钟了解!拱趴大菠萝有什么挂,hhpoker免费辅助器,本来真的有挂(竟然有挂)9分钟了解!拱趴大...
每日必备!德州局透视,如何判断... 每日必备!德州局透视,如何判断wpk辅助软件的真假,真是存在有挂(有挂存在)1、下载好脚本下载之后点...
推荐十款!hhpoker智能辅... 推荐十款!hhpoker智能辅助插件,hhpoker免费透视脚本,好像是有挂(发现有挂)1、游戏颠覆...
普及知识!哈糖大菠萝有挂吗,a... 普及知识!哈糖大菠萝有挂吗,aa poker透视软件,好像真的有挂(有挂实锤)1、金币登录送、破产送...
我来教教你!wpk辅助插件,佛... 我来教教你!wpk辅助插件,佛手在线大菠萝辅助,本来存在有挂(有挂透视)运佛手在线大菠萝辅助辅助工具...
分辨真假!pokernow辅助... 分辨真假!pokernow辅助控制,wepoker好友助力码,一贯有挂(有挂分析)小薇(辅助器软件下...
最新技巧!fishpoker透... 最新技巧!fishpoker透视底牌,wpk透视辅助靠谱吗,总是是真的有挂(有挂秘笈)1、最新技巧!...
三分钟了解!wpk有作弊吗,有... 三分钟了解!wpk有作弊吗,有哪些免费的wpk作弊码,总是真的是有挂(有挂细节)在进入软件靠谱后,参...
带你了解!wpk私人局辅助是真... 带你了解!wpk私人局辅助是真的吗,sohoo辅助,总是真的是有挂(证实有挂)1、玩家可以在线上大神...