SyncTask2.cs

using System;
using System.Threading.Tasks;
 
namespace Waher.Runtime.Threading.Sync
{
    public class SyncTask2<ReturnType, Arg1Type, Arg2Type> : ISyncTask
    {
        protected readonly TaskCompletionSource<ReturnType> task;
 
        private readonly Callback2<ReturnType, Arg1Type, Arg2Type> callback;
        private readonly Arg1Type arg1;
        private readonly Arg2Type arg2;
 
        public SyncTask2(Callback2<ReturnType, Arg1Type, Arg2Type> Callback, Arg1Type Arg1, Arg2Type Arg2)
        {
            this.task = new TaskCompletionSource<ReturnType>();
            this.callback = Callback;
            this.arg1 = Arg1;
            this.arg2 = Arg2;
        }
 
        public void Execute()
        {
            try
            {
                this.task.TrySetResult(this.callback(this.arg1, this.arg2));
            }
            catch (Exception ex)
            {
                this.task.TrySetException(ex);
            }
        }
 
        public Task<ReturnType> WaitAsync() => this.task.Task;
    }
}