internal/telemetry/stats/worker.go

// Copyright 2019 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package stats

import (
	"fmt"
	"os"
)

var (
	// TODO: Think about whether this is the right concurrency model, and what
	// TODO: the queue length should be
	workQueue = make(chan func(), 1000)
)

func init() {
	go func() {
		for task := range workQueue {
			task()
		}
	}()
}

// do adds a task to the list of things to work on in the background.
// All tasks will be handled in submission order, and no two tasks will happen
// concurrently so they do not need to do any kind of locking.
// It is safe however to call Do concurrently.
// No promises are made about when the tasks will be performed.
// This function may block, but in general it will return very quickly and
// before the task has been run.
func do(task func()) {
	select {
	case workQueue <- task:
	default:
		fmt.Fprint(os.Stderr, "work queue is full\n")
		workQueue <- task
	}
}