feat(async): change worker gr lifetime (#4) (#9)

.vscode/settings.json

@@ -16,25 +16,32 @@
     "exportloopref",
     "extendio",
     "fieldalignment",
+    "gobby",
     "goconst",
     "gocritic",
     "gocyclo",
     "gofmt",
     "goimports",
+    "goleak",
     "gomnd",
     "gosec",
     "gosimple",
     "govet",
     "graffico",
     "ineffassign",
     "jibberjabber",
+    "leaktest",
     "linters",
+    "lorax",
     "nakedret",
+    "nolint",
     "nolintlint",
     "pixa",
     "prealloc",
     "repotoken",
     "sidewalk",
+    "skeletor",
+    "smaug",
     "staticcheck",
     "structcheck",
     "stylecheck",
@@ -45,6 +52,7 @@
     "unparam",
     "varcheck",
     "watchvc",
-    "watchvi"
+    "watchvi",
+    "xenomorph"
   ]
 }

async/pool-defs-internal.go

@@ -1,14 +1,15 @@
 package async
 
-type workerInfo[I, R any] struct {
-	job         Job[I]
-	resultsOut  ResultStreamOut[R]
-	finishedOut FinishedStreamOut
-}
-
 const (
 	// TODO: This is just temporary, channel size definition still needs to be
 	// fine tuned
 	//
 	DefaultChSize = 100
 )
+
+type workerWrapper[I any, R any] struct {
+	cancelChOut chan<- CancelWorkSignal
+	core        *worker[I, R]
+}
+
+type workersCollection[I, R any] map[WorkerID]*workerWrapper[I, R]

async/pool-defs.go

@@ -1,5 +1,9 @@
 package async
 
+const (
+	MaxWorkers = 100
+)
+
 // Job, this definition is very rudimentary and bears no resemblance to the final
 // version. The job definition should be data driven not functionally driven. We
 // could have a bind function/method that would bind data to the job fn.
@@ -11,6 +15,7 @@ package async
 //
 
 type Job[I any] struct {
+	ID    string
 	Input I
 }
 
@@ -39,3 +44,8 @@ type WorkerID string
 type FinishedStream = chan WorkerID
 type FinishedStreamIn = <-chan WorkerID
 type FinishedStreamOut = chan<- WorkerID
+
+// joinChannelsFunc allows reader channel to be joined to the writer channel. This
+// function is called when entry is found on the input and forwarded to the
+// output.
+type JoinChannelsFunc[T any] func(inCh <-chan T, outCh chan<- T)