weird_channels.jl

addprocs(3)

type AtomicTask
    category::Symbol
end

const jobs = RemoteChannel(()->Channel{AtomicTask}(Inf))
const results = RemoteChannel(()->Channel{Float64}(Inf))

@everywhere function execute_jobs(jobs, results)
    while true
        task = take!(jobs)

        if task.category == :a
            put!(jobs, AtomicTask(:b))

        elseif task.category == :b
            put!(jobs, AtomicTask(:c))
            put!(jobs, AtomicTask(:c))

        elseif task.category == :c
            put!(results, rand())
        end
    end
end


# ---------------- ----------------
@schedule put!(jobs, AtomicTask(:a))

for p in workers()
    remote_do(execute_jobs, p, jobs, results)
end