parallelworks

Documentation

Overview

Package parallelworks provides start parallel calls some function with collecting results

Index

• Constants
• type JobData
  • func (data JobData) WriteToChan(a chan<- JobData)
• type Worker
  • func (worker Worker) Run(dataList []JobData, workersCount int) map[int]interface{}

Constants

const (
	WorkersCount                    = 64
	WorkersCountToChanLenMultiplier = 2
)

Types

type JobData

type JobData struct {
	ID   int
	Data interface{}
}

func (JobData) WriteToChan

func (data JobData) WriteToChan(a chan<- JobData)

type Worker

type Worker func(data JobData) JobData

func (Worker) Run

func (worker Worker) Run(dataList []JobData, workersCount int) map[int]interface{}