concurrency

package

v1.0.4 Latest Latest Go to latest Published: Mar 12, 2026 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

func DotProduct(a, b []float32) float32

DotProduct 点积

func GetWorkerCount() int

GetWorkerCount 获取工作线程数

func ParallelSlice[T any](input []T, process func(T, int))

ParallelSlice 并发处理切片

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

WorkerPool 工作池

func NewWorkerPool(workers int) *WorkerPool

NewWorkerPool 创建工作池

func (wp *WorkerPool) BatchDot(vectors [][]float32, query []float32) []float32

WorkerPool 批量点积（并行版本）

func (wp *WorkerPool) Close()

Close 关闭工作池

func (wp *WorkerPool) Submit(task func())

Submit 提交任务

func (wp *WorkerPool) Wait()

Wait 等待所有任务完成