Multithreaded channel demonstration

channel-mt.jl

using Base.Threads: @spawn, nthreads, threadid

N = 100
chan = Channel(nthreads()) do chan
    for val in 1:N
        put!(chan, val)
        println("T$(threadid()) => put $(val)")
    end
end

workers = map(1:nthreads()) do _
    @spawn begin
        for val in chan
            println("T$(threadid()) => took $(val)")
        end
        println("T$(threadid()) => finished")
    end
end
foreach(wait, workers)