add Event(f, args; dependencies)

Author: vchuravy

src/backends/cpu.jl

@@ -6,6 +6,14 @@ function Event(::CPU)
     return NoneEvent()
 end
 
+function Event(f, args...; dependencies=nothing, progress=nothing)
+    T = Threads.@spawn begin
+        wait(MultiEvent(dependencies), progress)
+        f(args...)
+    end
+    return CPUEvent(T)
+end
+
 wait(ev::Union{CPUEvent, NoneEvent, MultiEvent}, progress=nothing) = wait(CPU(), ev, progress)
 wait(::CPU, ev::NoneEvent, progress=nothing) = nothing
 

test/events.jl

@@ -0,0 +1,22 @@
+using KernelAbstractions
+using Test
+
+@testset "Error propagation" begin
+    let event = Event(()->error(""))
+        @test_throws TaskFailedException wait(event)
+    end
+
+    let event = Event(error, "")
+        @test_throws CompositeException wait(MultiEvent(event))
+    end
+
+    let event = Event(error, "")
+        event = Event(wait, MultiEvent(event))
+        @test_throws TaskFailedException wait(event)
+    end
+
+    let event = Event(error, "")
+        event = Event(()->nothing, dependencies=event)
+        @test_throws TaskFailedException wait(event)
+    end
+end

test/runtests.jl

@@ -21,6 +21,10 @@ end
     include("nditeration.jl")
 end
 
+@testset "Events" begin
+    include("events.jl")
+end
+
 include("print_test.jl")
 
 include("examples.jl")