Add wally toml and move to src folder

Author: dig

default.project.json

@@ -1,6 +1,6 @@
 {
-  "name": "roblox-lua-parallel",
+  "name": "parallel",
   "tree": {
-    "$path": "lib"
+    "$path": "src"
   }
 }

lib/ClientActor/Worker.lua src/ClientActor/Worker.lualib/ClientActor/Worker.lua renamed to src/ClientActor/Worker.lua

@@ -16,9 +16,13 @@ export type PreparedParallel = {
   destroy: () -> (),
 }
 
+type ActorStateMap = {
+  [Actor]: ActorState,
+}
+
 type ActorState = {
   count: number,
-  running: {Promise},
+  running: { [Promise]: boolean },
 }
 
 -- Set correct worker folder depending on
@@ -37,16 +41,17 @@ local Parallel = {}
 Parallel.__index = Parallel
 
 function Parallel.of(runnable: (...any?) -> any?): PreparedParallel
+  assert(type(runnable) == "function", "Runnable must be a function")
   local self = setmetatable({
     _runnable = runnable,
     _name = "ParallelWorker",
     _actorCount = 1,
     _bindableEvent = Instance.new("BindableEvent"),
     _folder = Instance.new("Folder"),
 
-    _actors = {},
-    _actorState = {} :: ActorState,
-    _results = {},
+    _actors = {} :: { Actor },
+    _actorState = {} :: ActorStateMap,
+    _results = {} :: { [string]: table },
 
     _connection = nil,
     _destroyed = false,
@@ -63,13 +68,17 @@ end
 
 function Parallel:withName(name: string): PreparedParallel
   assert(not self._destroyed, "Parallel destroyed")
+  assert(type(name) == "string", "Name must be a string")
+  assert(#name > 0, "Name must be non-empty")
   self._name = name
   self._folder.Name = name
   return self
 end
 
 function Parallel:withActors(actorCount: number): PreparedParallel
   assert(not self._destroyed, "Parallel destroyed")
+  assert(type(actorCount) == "number", "Actor count must be a number")
+  assert(actorCount > 0, "Actor count must be greater than 0")
   self._actorCount = actorCount
   self:_createActors()
   return self
@@ -121,15 +130,13 @@ end
 function Parallel:destroy()
   assert(not self._destroyed, "Parallel already destroyed")
   self._destroyed = true
-
   self._connection:Disconnect()
   self._connection = nil
 
   for _, actor in self._actors do
     for runningPromise, _ in self._actorState[actor].running do
       runningPromise:cancel()
     end
-
     actor:SendMessage("Parallel:Destroy")
   end
 
@@ -139,18 +146,17 @@ function Parallel:destroy()
 
   self._bindableEvent:Destroy()
   self._bindableEvent = nil
-
   self._folder:Destroy()
   self._folder = nil
 end
 
 function Parallel:_findAvailableActor(): Actor
   assert(#self._actors > 0, "No available actors")
-  
-  -- Find actor with least running promises
-  local min = 999_999
-  local minActor = nil
-  for _, actor in self._actors do
+  local min = self._actors[1]
+  local minActor = self._actorState[min].count
+
+  for i = 2, #self._actors do
+    local actor = self._actors[i]
     local count = self._actorState[actor].count
     if count < min then
       min = count
@@ -187,7 +193,7 @@ function Parallel._createTemplatedActor(): Actor
 end
 
 function Parallel:__tostring()
-  return string.format("Parallel(%s)", self._name)
+  return string.format("Parallel<%s>", self._name)
 end
 
 return Parallel

lib/ClientActor/init.meta.json src/ClientActor/init.meta.jsonlib/ClientActor/init.meta.json renamed to src/ClientActor/init.meta.json

@@ -0,0 +1,11 @@
+[package]
+name = "dig/parallel"
+description = "Parallel execution library for Roblox lua"
+version = "1.0.0"
+license = "MIT"
+registry = "https://github.com/UpliftGames/wally-index"
+realm = "shared"
+include = ["src", "default.project.json"]
+
+[dependencies]
+Promise = "evaera/promise@4.0.0"