Make accesses to __iNtErNaL_running_procs thread-safe

Author: giordano

Project.toml

@@ -1,7 +1,7 @@
 name = "Malt"
 uuid = "36869731-bdee-424d-aa32-cab38c994e3b"
 authors = ["Sergio Alejandro Vargas <savargasqu+git@unal.edu.co>", "Fons van der Plas <fons@plutojl.org>"]
-version = "1.4.0"
+version = "1.4.1"
 
 [deps]
 Distributed = "8ba89e20-285c-5b6f-9357-94700520ee1b"

src/Malt.jl

@@ -75,7 +75,8 @@ 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)
+const procs_lock = ReentrantLock()
+__iNtErNaL_get_running_procs() = Base.@lock procs_lock filter!(Base.process_running, __iNtErNaL_running_procs)
 
 """
     Malt.Worker()
@@ -134,7 +135,7 @@ mutable struct Worker <: AbstractWorker
 
         # Keep internal list
         __iNtErNaL_get_running_procs()
-        push!(__iNtErNaL_running_procs, proc)
+        Base.@lock procs_lock push!(__iNtErNaL_running_procs, proc)
 
         yield() # https://github.com/fonsp/Pluto.jl/issues/3423