add lock around serialize

krynju · Dec 19, 2021 · fb605fa · fb605fa
1 parent 6817551
commit fb605fa
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/stdlib/Distributed/src/remotecall.jl b/stdlib/Distributed/src/remotecall.jl
@@ -370,7 +370,9 @@ function serialize(s::ClusterSerializer, f::Future)
         p = worker_id_from_socket(s.io)
         (p !== f.where) && send_add_client(f, p)
     end
-    invoke(serialize, Tuple{ClusterSerializer, Any}, s, f)
+    @lock f.lock begin
+        invoke(serialize, Tuple{ClusterSerializer, Any}, s, f)
+    end
 end
 
 function serialize(s::ClusterSerializer, rr::RemoteChannel)