workerpool

package

v1.0.0 Latest Latest Go to latest Published: Jul 15, 2024 License: BSD-3-Clause Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Pool struct {
	Tasks   []*Task
	Workers []*Worker
	// contains filtered or unexported fields
}

Pool воркера

func NewPool(tasks []*Task, concurrency int) *Pool

NewPool инициализирует новый пул с заданными задачами и

func (p *Pool) AddTask(task *Task)

func (p *Pool) Run()

func (p *Pool) RunBackground()

func (p *Pool) Stop()

type Task struct {
	Err  error
	Data *url.URL
	// contains filtered or unexported fields
}

func NewTask(f func(interface{}) error, data *url.URL) *Task

type Worker struct {
	ID int
	// contains filtered or unexported fields
}

Worker контролирует всю работу

func NewWorker(channel chan *Task, ID int) *Worker

NewWorker возвращает новый экземпляр worker-а

func (wr *Worker) Start(wg *sync.WaitGroup)

Start запуск worker

func (wr *Worker) StartBackground()

func (wr *Worker) Stop()