fix deadlock

2024-09-10 14:38:46 +08:00
parent 3f9e86c37a
commit 7f4022120e
1 changed files with 4 additions and 2 deletions
--- a/x/async/async_go.go
+++ b/x/async/async_go.go
@@ -37,8 +37,10 @@ func Async[T any](fn func(func(T))) Future[T] {
 	})

 	return func(chain func(T)) {
-		wg.Wait()
-		chain(result)
+		go func() {
+			wg.Wait()
+			chain(result)
+		}()
 	}
 }