make dict of Threads.Condition

Author: dehann

src/entities/DFGVariable.jl

@@ -32,9 +32,9 @@ mutable struct VariableNodeData{T<:InferenceVariable}
     dontmargin::Bool
     solveInProgress::Int
     solvedCount::Int
-    event::Threads.Condition #This object is NOT thread-safe. See Threads.Condition for a thread-safe version. julia 1.2
+    events::Dict{Symbol,Threads.Condition}
     VariableNodeData{T}() where {T <:InferenceVariable} =
-    new{T}(zeros(1,1), zeros(1,1), Symbol[], Int[], 0, false, :NOTHING, Symbol[], T(), false, 0.0, false, false, 0, 0, Condition())
+    new{T}(zeros(1,1), zeros(1,1), Symbol[], Int[], 0, false, :NOTHING, Symbol[], T(), false, 0.0, false, false, 0, 0, Dict{Symbol,Threads.Condition}())
     VariableNodeData{T}(val::Array{Float64,2},
                         bw::Array{Float64,2},
                         BayesNetOutVertIDs::Array{Symbol,1},
@@ -49,11 +49,11 @@ mutable struct VariableNodeData{T<:InferenceVariable}
                         dontmargin::Bool,
                         solveInProgress::Int=0,
                         solvedCount::Int=0,
-                        eventCondition::Condition=Condition()) where T <: InferenceVariable =
+                        events::Dict{Symbol,Threads.Condition}=Dict{Symbol,Threads.Condition}()) where T <: InferenceVariable =
                             new{T}(val,bw,BayesNetOutVertIDs,dimIDs,dims,
                                    eliminated,BayesNetVertID,separator,
                                    softtype::T,initialized,inferdim,ismargin,
-                                   dontmargin, solveInProgress, solvedCount, eventCondition)
+                                   dontmargin, solveInProgress, solvedCount, events)
 end
 
 ##------------------------------------------------------------------------------