Server : Apache/2.4.41 (Ubuntu) System : Linux absol.cf 5.4.0-198-generic #218-Ubuntu SMP Fri Sep 27 20:18:53 UTC 2024 x86_64 User : www-data ( 33) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare, Directory :  /var/lib/gems/2.5.0/gems/em-synchrony-1.0.3/examples/go/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

require 'go'

EM.synchrony do
  def producer(c, n, s)
    n.times do |i|
      puts "producer: #{i}"
      c << i
    end

    s << "producer finished"
  end

  consumer = ->(c, n, s) do
    n.times do |i|
      puts "consumer 1 got: #{c.pop}"
    end

    s << "consumer finished"
  end

  c = Channel.new(size: 2)
  s = Channel.new
  n = 10

  # mix the syntax, just for fun...
  go c,n,s, &method(:producer)
  go c,n-1,s, &consumer

  go c,s do |c, s|
    puts "consumer 2 got: #{c.pop}"
    s << "consumer 2 finished"
  end

  3.times { puts s.pop }

  EM.stop
end

# (M=6c0863) igrigorik /git/em-synchrony/examples/go> ruby consumer-publisher.rb
# producer: 0
# producer: 1
# consumer 1 got: [0]
# producer: 2
# consumer 2 got: [1]
# producer: 3
# consumer 1 got: [2]
# producer: 4
# consumer 2 finished
# consumer 1 got: [3]
# producer: 5
# consumer 1 got: [4]
# producer: 6
# consumer 1 got: [5]
# producer: 7
# consumer 1 got: [6]
# producer: 8
# consumer 1 got: [7]
# producer: 9
# consumer 1 got: [8]
# consumer 1 got: [9]
# producer finished
# consumer finished