goroutines

package workpool

import (
	"context"
	"sync"
)

package worker

import (
	"context"
	"errors"
	"log"

package pipeline

import "context"

func generate(ctx context.Context, nums ...int) <-chan int {
	out := make(chan int)

package worker

import "context"

func (p *Pool) Submit(job Job) error {
	// Reject fast if draining, otherwise enqueue with backpressure.

package pqueue

type Job struct {
	ID       string
	Payload  interface{}
	Priority int

package scheduler

import (
	"context"
	"log"
	"sync"

package sse

type Broker struct {
	subscribers map[chan []byte]struct{}
	subscribe   chan chan []byte
	unsubscribe chan chan []byte

package limiter

import (
	"context"
	"errors"
)

package watch

import (
	"sync"
	"time"
)

package main

import (
	"context"
	"log"
	"net/http"

package quotes

import (
	"context"
	"encoding/json"
	"fmt"

package pricecache

import (
	"context"
	"sync"