heartbeat-01.go

package main

import (
	"fmt"
	"time"
)

func main() {

	doWork := func(
		done <-chan interface{},
		pulseInterval time.Duration,
	) (<-chan interface{}, <-chan time.Time) {

		// 1. Here we set up a channel to send heartbeats on
		heartbeat := make(chan interface{})
		results := make(chan time.Time)

		go func() {
			// defer close(heartbeat)
			// defer close(results)

			// 2. Here we set the heartbeat to pulse at the pulseInterval we were given.
			// Every pulseInterval there will be something to read on this channel.
			pulse := time.Tick(pulseInterval)

			// 3. This is just another ticker used to simulate work coming in. We choose
			// a duration greater than pulse interval so that we can see some heartbeats
			// coming out of the goroutine.
			workGen := time.Tick(2 * pulseInterval)

			sendPulse := func() {
				select {
				case heartbeat <- struct{}{}:
				// 4. Note that we include a default clause. We must always guard against the fact
				// that no one may be listening to our heartbeat. The results emitted from the goroutine are
				// critical, but the pulses are not.
				default:
				}
			}

			sendResult := func(r time.Time) {
				for {
					select {
					case <-done:
						return
					// 5. Just like with done channels, anytime you perform a send or receive, you
					// also need to include a case for the heartbeat's pulse.
					case <-pulse:
						sendPulse()
					case results <- r:
						return
					}
				}
			}

			// for {
			// 	select {
			// 	case <-done:
			// 		return
			// 	case <-pulse: // 5.
			// 		sendPulse()
			// 	case r := <-workGen:
			// 		sendResult(r)
			// 	}
			// }

			for i := 0; i < 2; i++ {
				select {
				case <-done:
					return
				case <-pulse: // 5.
					sendPulse()
				case r := <-workGen:
					sendResult(r)
				}
			}

		}()
		return heartbeat, results
	}

	// USAGE

	done := make(chan interface{})
	time.AfterFunc(10*time.Second, func() { close(done) })

	const timeout = 2 * time.Second
	heartbeat, results := doWork(done, timeout/2)
	for {
		select {
		case _, ok := <-heartbeat:
			if ok == false {
				return
			}
			fmt.Println("pulse")
		case r, ok := <-results:
			if ok == false {
				return
			}
			fmt.Printf("results: %v\n", r.Second())
		case <-time.After(timeout):
			fmt.Println("worker goroutine is not healthy")
			return
		}
	}

}