SyncTask0.cs

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