Merge pull request #473 from isaacsas/threading_fix

don't access callbacks till checking they exist

Author: ChrisRackauckas

src/solve.jl

@@ -47,8 +47,8 @@ end
 
 function resetted_jump_problem(_jump_prob, seed)
     jump_prob = deepcopy(_jump_prob)
-    rng = jump_prob.jump_callback.discrete_callbacks[1].condition.rng
     if !isempty(jump_prob.jump_callback.discrete_callbacks)
+        rng = jump_prob.jump_callback.discrete_callbacks[1].condition.rng
         if seed === nothing
             Random.seed!(rng, rand(UInt64))
         else

test/thread_safety.jl

@@ -1,5 +1,5 @@
 using DiffEqBase
-using JumpProcesses
+using JumpProcesses, OrdinaryDiffEq
 using StableRNGs
 rng = StableRNG(12345)
 
@@ -13,3 +13,19 @@ jprob = JumpProblem(dprob, Direct(), maj; rng = rng)
 solve(EnsembleProblem(jprob), SSAStepper(), EnsembleThreads(); trajectories = 10)
 solve(EnsembleProblem(jprob; safetycopy = true), SSAStepper(), EnsembleThreads();
     trajectories = 10)
+
+# test for https://github.com/SciML/JumpProcesses.jl/issues/472
+let
+    function f!(du, u, p, t)
+        du[1] = -u[1]
+        nothing 
+    end
+    u_0 = [1.0]
+    ode_prob = ODEProblem(f!, u_0, (0.0, 10))
+    rate(u, p, t) = 1.0
+    jump!(integrator) = nothing
+    jump_prob = JumpProblem(ode_prob, Direct(), VariableRateJump(rate, jump!); rng)
+    prob_func(prob, i, repeat) = deepcopy(prob)
+    prob = EnsembleProblem(jump_prob,prob_func = prob_func)
+    solve(prob, Tsit5(), EnsembleThreads(), trajectories=10)
+end