SyncTask1.cs

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