Add Interrupt and Initialize as events

Author: BenLauwens

docs/src/examples/ross.md

@@ -36,7 +36,11 @@ const G = Exponential(MU)
         @yield Timeout(env, rand(F))
         get_spare = Get(spares)
         @yield get_spare | Timeout(env)
-        state(get_spare) != SimJulia.idle ? interrupt(value(get_spare)) : throw(SimJulia.StopSimulation("No more spares!"))
+        if state(get_spare) != SimJulia.idle 
+            interrupt(value(get_spare))
+        else
+            throw(SimJulia.StopSimulation("No more spares!"))
+        end
         @yield Request(repair_facility)
         @yield Timeout(env, rand(G))
         @yield Release(repair_facility)

src/events.jl

@@ -21,6 +21,20 @@ struct Timeout <: AbstractEvent
   end
 end
 
+struct Initialize <: AbstractEvent
+  bev :: BaseEvent
+  function Initialize(env::Environment)
+    schedule(new(BaseEvent(env)))
+  end
+end
+
+struct Interrupt <: AbstractEvent
+  bev :: BaseEvent
+  function Interrupt(env::Environment)
+    new(BaseEvent(env))
+  end
+end
+
 function run(env::Environment, until::Number=typemax(Float64))
   run(env, Timeout(env, until-now(env)))
-end
+end

src/processes.jl

@@ -7,7 +7,7 @@ mutable struct Process <: DiscreteProcess
     cor = new()
     cor.bev = BaseEvent(env)
     cor.fsmi = func(env, args...)
-    cor.target = Timeout(env)
+    cor.target = Initialize(env)
     cor.resume = @callback execute(cor.target, cor)
     cor
   end
@@ -38,7 +38,7 @@ end
 function interrupt(proc::Process, cause::Any=nothing)
   if !done(proc.fsmi)
     remove_callback(proc.resume, proc.target)
-    proc.target = Timeout(environment(proc); priority=typemax(Int8), value=InterruptException(proc, cause))
+    proc.target = schedule(Interrupt(environment(proc)); priority=typemax(Int8), value=InterruptException(proc, cause))
     proc.resume = @callback execute(proc.target, proc)
   end
 end