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

相关内容

热门资讯

四分钟了解!哈局十三张,大赢家... 四分钟了解!哈局十三张,大赢家跑得快辅助,分享教程(有挂脚本)1、大赢家跑得快辅助系统规律教程、大赢...
8分钟了解!星星武汉麻将胡牌技... 8分钟了解!星星武汉麻将胡牌技巧,赣牌圈开挂是真的吗,科技教程(有挂揭秘)1、进入游戏-大厅左侧-新...
4分钟了解!菠萝德州app有挂... 4分钟了解!菠萝德州app有挂吗,新玉海楼茶苑吗,必胜教程(有挂神器)1、在菠萝德州app有挂吗ai...
6分钟了解!微友麻将,浙江游戏... 6分钟了解!微友麻将,浙江游戏大厅有猫腻吗,透视教程(有挂解说)亲,关键说明,浙江游戏大厅有猫腻吗赛...
一分钟了解!斗棋红中胡牌有没有... 一分钟了解!斗棋红中胡牌有没有什么规律,开心十三张有没有挂,2025版教程(有挂技巧);暗藏猫腻,小...
2分钟了解!琼崖海南麻将怎么提... 2分钟了解!琼崖海南麻将怎么提高胜率,福建天天开心王国辅助器,揭秘教程(有挂工具)一、琼崖海南麻将怎...
八分钟了解!乐乐游戏辅助器,众... 八分钟了解!乐乐游戏辅助器,众乐联盟有挂吗,可靠教程(有挂透视)1、全新机制【众乐联盟有挂吗软件透明...
一分钟了解!雀神麻将辅牌器购买... 一分钟了解!雀神麻将辅牌器购买,微信随意玩9人拼三张辅助器,实用技巧(有挂秘籍)1、用户打开应用后不...
二分钟了解!新华棋牌有没有挂,... 二分钟了解!新华棋牌有没有挂,打小闲川南棋牌为什么总是输,揭秘教程(有挂软件)暗藏猫腻,小编详细说明...
三分钟了解!汇友手游外 挂,边... 三分钟了解!汇友手游外 挂,边锋干瞪眼外挂效果,必备教程(有挂软件)进入游戏-大厅左侧-新手福利-激...