SharpIDE/src/SharpIDE.Godot/NodeExtensions.cs

using System;
using System.Threading.Tasks;
using Godot;

namespace SharpIDE.Godot;

public static class NodeExtensions
{
    public static Task InvokeAsync(this Node node, Action workItem)
    {
        var taskCompletionSource = new TaskCompletionSource();
        //WorkerThreadPool.AddTask();
        Callable.From(() =>
        {
            try
            {
                workItem();
                taskCompletionSource.SetResult();
            }
            catch (Exception ex)
            {
                taskCompletionSource.SetException(ex);
            }
        }).CallDeferred();
        return taskCompletionSource.Task;
    }
    
    public static Task InvokeAsync(this Node node, Func<Task> workItem)
    {
        var taskCompletionSource = new TaskCompletionSource();
        //WorkerThreadPool.AddTask();
        Callable.From(async void () =>
        {
            try
            {
                await workItem();
                taskCompletionSource.SetResult();
            }
            catch (Exception ex)
            {
                taskCompletionSource.SetException(ex);
            }
        }).CallDeferred();
        return taskCompletionSource.Task;
    }
}

public static class GodotTask
{
    public static async Task Run(Action action)
    {
        await Task.Run(() =>
        {
            try
            {
                action();
            }
            catch (Exception ex)
            {
                GD.PrintErr($"Error: {ex}");
            }
        });
    }
    
    public static async Task Run(Func<Task> action)
    {
        await Task.Run(async () =>
        {
            try
            {
                await action();
            }
            catch (Exception ex)
            {
                GD.PrintErr($"Error: {ex}");
            }
        });
    }
}