WorkItem.cs

using System.Threading;
using System.Threading.Tasks;
 
namespace Waher.Runtime.Queue
{
    public abstract class WorkItem : IWorkItem
    {
        private readonly TaskCompletionSource<bool> processed = new TaskCompletionSource<bool>();
 
        public Task Execute()
        {
            return this.Execute(CancellationToken.None);
        }
 
        public abstract Task Execute(CancellationToken Cancel);
 
        public void Processed(bool Result)
        {
            this.processed.TrySetResult(Result);
        }
 
        public Task<bool> Wait()
        {
            return this.processed.Task;
        }
 
        public Task<bool> Wait(CancellationToken Cancel)
        {
            if (Cancel.CanBeCanceled)
                Cancel.Register(() => this.processed.TrySetResult(false));
 
            return this.processed.Task;
        }
    }
}