workerpool

Documentation

Overview

Package workerpool provides a persistent pool of goroutines that process submitted tasks. It replaces per-call goroutine spawning in GEMV and element-wise operations.

Index

• type Pool
  • func New(n int) *Pool
  • func (p *Pool) Close()
  • func (p *Pool) Submit(tasks []func())

Types

type Pool

type Pool struct {
	// contains filtered or unexported fields
}

Pool is a fixed-size pool of long-lived worker goroutines.

func New

func New(n int) *Pool

New creates a pool with n worker goroutines that block on a shared task channel.

func (*Pool) Close

func (p *Pool) Close()

Close shuts down the pool. It is safe to call multiple times.

func (*Pool) Submit

func (p *Pool) Submit(tasks []func())

Submit sends all tasks to the pool and blocks until every task completes.