add TrajectStyle

Author: findmyway

src/trajectory.jl

@@ -1,7 +1,10 @@
-export Trajectory
+export Trajectory, TrajectoryStyle, SyncTrajectoryStyle, AsyncTrajectoryStyle
 
 using Base.Threads
 
+struct AsyncTrajectoryStyle end
+struct SyncTrajectoryStyle end
+
 
 """
     Trajectory(container, sampler, controler)
@@ -53,6 +56,16 @@ Base.@kwdef struct Trajectory{C,S,T}
     end
 end
 
+TrajectoryStyle(::Trajectory) = SyncTrajectoryStyle()
+TrajectoryStyle(::Trajectory{<:Any,<:Any,<:AsyncInsertSampleRatioControler}) = AsyncTrajectoryStyle()
+
+Base.bind(::Trajectory, ::Task) = nothing
+
+function Base.bind(t::Trajectory{<:Any,<:Any,<:AsyncInsertSampleRatioControler}, tassk)
+    bind(t.controler.ch_in, task)
+    bind(t.controler.ch_out, task)
+end
+
 
 Base.push!(t::Trajectory; kw...) = push!(t, values(kw))