Fix tasks not being removed and change actor select to round robin

Author: dig

README.md

@@ -13,7 +13,7 @@ Read more about Parallel Luau here: [Parallel Luau](https://create.roblox.com/do
 2. Add the dependency to your project's `wally.toml` file
 ```toml
 [dependencies]
-Parallel = "dig/parallel@1.0.4"
+Parallel = "dig/parallel@1.0.5"
 ```
 3. Run `wally install`
 

src/ClientActor/Worker.client.luau

@@ -25,6 +25,7 @@ actor:BindToMessage("Parallel:SubmitTask", function(uuid: string, ...: any?)
     -- PARALLEL: Switch to parallel thread
     task.desynchronize()
     bindableEvent:Fire(uuid, preparedRunnable(table.unpack(args)))
+    tasks[uuid] = nil
   end)
 end)
 

src/ServerActor/Worker.server.luau

@@ -25,6 +25,7 @@ actor:BindToMessage("Parallel:SubmitTask", function(uuid: string, ...: any?)
     -- PARALLEL: Switch to parallel thread
     task.desynchronize()
     bindableEvent:Fire(uuid, preparedRunnable(table.unpack(args)))
+    tasks[uuid] = nil
   end)
 end)
 

src/init.luau

@@ -83,6 +83,7 @@ function Parallel.of(runnable: ModuleScript): PreparedParallel
     _actors = {} :: { Actor },
     _actorState = {} :: ActorStateMap,
     _results = {} :: { [string]: table },
+    _actorIndex = 1,
 
     _connection = nil,
     _destroyed = false,
@@ -111,6 +112,7 @@ function Parallel:withActors(actorCount: number): PreparedParallel
   assert(type(actorCount) == "number", "Actor count must be a number")
   assert(actorCount > 0, "Actor count must be greater than 0")
   self._actorCount = actorCount
+  self._actorIndex = math.min(self._actorIndex, actorCount)
   self:_createActors()
   return self
 end
@@ -184,19 +186,14 @@ end
 
 function Parallel:_findActor(): Actor
   assert(#self._actors > 0, "No actors")
-  local minActor = self._actors[1]
-  local min = self._actorState[minActor].count
-
-  for i = 2, #self._actors do
-    local actor = self._actors[i]
-    local count = self._actorState[actor].count
-    if count < min then
-      min = count
-      minActor = actor
-    end
+  local actor = self._actors[self._actorIndex]
+
+  self._actorIndex += 1
+  if self._actorIndex > #self._actors then
+    self._actorIndex = 1
   end
 
-  return minActor
+  return actor
 end
 
 function Parallel:_createActors()

wally.toml

@@ -1,7 +1,7 @@
 [package]
 name = "dig/parallel"
 description = "Parallel execution library for Roblox lua"
-version = "1.0.4"
+version = "1.0.5"
 license = "MIT"
 registry = "https://github.com/UpliftGames/wally-index"
 realm = "shared"