src/ZKEACMS.Mail/Queue/BlockedEmailQueueReader.cs

（完整代码） 1005B 

using Easy.Notification;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace ZKEACMS.Mail.Queue
{
    public class BlockedEmailQueueReader
    {
        private readonly PersistentEmailQueue _emailQueue;
        private EmailContext emailContext;
        public BlockedEmailQueueReader(PersistentEmailQueue emailQueue, CancellationToken cancellationToken)
        {
            _emailQueue = emailQueue;
            Task = new Task<EmailContext>(GetCurrentContext, cancellationToken);
        }

        public async Task<bool> TryDequeueAsync()
        {
            emailContext = await _emailQueue.ReceiveFromFileAsync();
            if (emailContext == null) return false;

            Task.Start();
            return true;
        }

        public Task<EmailContext> Task { get; private set; }
        EmailContext GetCurrentContext()
        {
            return emailContext;
        }
    }
}

24 小时内免费解锁 3 个项目，之后 1 算力/个。 规则说明

AI 解读 AI

登录后可用，每次 10 算力，解读结果公开显示在下面。

还没有人解读过这个文件。