Update RefdsTask.swift

rafaelesantos · Aug 22, 2024 · 0e2d333 · 0e2d333
1 parent 17956e3
commit 0e2d333
Showing 1 changed file with 14 additions and 2 deletions.
diff --git a/Sources/RefdsShared/Task/RefdsTask.swift b/Sources/RefdsShared/Task/RefdsTask.swift
@@ -2,7 +2,8 @@ import Foundation
 
 public protocol RefdsTaskProtocol {
     typealias ExecuteItem = () -> Void
-    func execute(items: [ExecuteItem])
+    func concurrent(items: [ExecuteItem])
+    func sequential(items: [ExecuteItem])
 }
 
 public final class RefdsTask: RefdsTaskProtocol {
@@ -23,7 +24,7 @@ public final class RefdsTask: RefdsTaskProtocol {
         )
     }
 
-    public func execute(items: [ExecuteItem]) {
+    public func concurrent(items: [ExecuteItem]) {
         items.forEach { item in
             group.enter()
             queue.async {
@@ -33,4 +34,15 @@ public final class RefdsTask: RefdsTaskProtocol {
         }
         group.wait()
     }
+
+    public func sequential(items: [ExecuteItem]) {
+        items.forEach { item in
+            group.enter()
+            queue.async {
+                item()
+                self.group.leave()
+            }
+            group.wait()
+        }
+    }
 }