go-eventcast's Introduction

eventcast

Simple event broadcasting.

Examples

Signaling arbitrary number of workers

  // spawn workers
  for i := 0; i < 100; i++ {
    go func() {
      closed := eventcast.Listen("we are closed")
      for {
        select {
        case <-closed:
          return
        default:
          // do other things
        }
      }
    }()
  }

  // somewhere, sometime later..
  eventcast.Broadcast("we are closed")

Broadcasting a value to multiple listeners

  // goroutines waiting for some result or timeout.
  for i := 0; i < 10; i++ {
    go func() {
      select {
      case value := <-eventcast.Listen("result"):
        // do something with value
      case <-time.After(1 * time.Second):
        // timeout!
        break
      }
    }()
  }

  // some worker
  go func() {
    // doing something...

    value := "result of processing some data"
    eventcast.BroadcastWithValue("result", value)

    // continue doing more
  }()

Racing Your Pigs

  // go pig!
  finished := eventcast.Listen("finished")
  for i := 0; i < 10; i++ {
    go func(i int) {
      <-eventcast.Listen("ready")
      <-eventcast.Listen("set")
      <-eventcast.Listen("go")
      time.Sleep(time.Duration(rand.Intn(5000)) * time.Millisecond)
      eventcast.BroadcastWithValue("finished", i)
    }(i)
  }

  // Allow some time for the pigs to get ready
  <-time.After(10 * time.Milisecond)

  eventcast.Broadcast("ready")
  <-time.After(1 * time.Second)

  eventcast.Broadcast("set")
  <-time.After(1 * time.Second)

  eventcast.Broadcast("go")
  winner := <-finished
  fmt.Println("Winner is Pig", winner.(int))

go-eventcast's People