Add __iNtErNaL_running_procs

Project.toml

@@ -1,7 +1,7 @@
 name = "Malt"
 uuid = "36869731-bdee-424d-aa32-cab38c994e3b"
 authors = ["Sergio Alejandro Vargas <[email protected]>"]
-version = "1.0.0"
+version = "1.0.1"
 
 [deps]
 Distributed = "8ba89e20-285c-5b6f-9357-94700520ee1b"

src/Malt.jl

@@ -72,6 +72,9 @@ end
 
 Base.summary(io::IO, w::InProcessWorker) = write(io, "Malt.InProcessWorker in module $(w.host_module)")
 
+const __iNtErNaL_running_procs = Set{Base.Process}()
+__iNtErNaL_get_running_procs() = filter!(Base.process_running, __iNtErNaL_running_procs)
+
 """
     Malt.Worker()
 
@@ -98,6 +101,10 @@ mutable struct Worker <: AbstractWorker
         # Spawn process
         cmd = _get_worker_cmd(; env, exeflags)
         proc = open(cmd, "w+")
+
+        # Keep internal list
+        __iNtErNaL_get_running_procs()
+        push!(__iNtErNaL_running_procs, proc)
 
         # Block until reading the port number of the process (from its stdout)
         port_str = readline(proc)

test/basic.jl

@@ -10,9 +10,11 @@
         w = W()
         @test m.isrunning(w) === true
 
+        W === m.Worker && @test length(m.__iNtErNaL_get_running_procs()) == 1
         # Terminating workers takes about 0.5s
         m.stop(w)
         @test m.isrunning(w) === false
+        W === m.Worker && @test length(m.__iNtErNaL_get_running_procs()) == 0
     end
 
 

test/runtests.jl

@@ -1,11 +1,18 @@
 import Malt as m
 using Test
 
+
+v() = @assert isempty(m.__iNtErNaL_get_running_procs())
+
+v()
 include("basic.jl")
+v()
 include("exceptions.jl")
+v()
 include("nesting.jl")
+v()
 include("benchmark.jl")
-
+v()
 
 
 #TODO: