workpool

Documentation

Overview

* Copyright (C) 2019 Zilliqa * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see <https://www.gnu.org/licenses/>.

* Copyright (C) 2019 Zilliqa * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see <https://www.gnu.org/licenses/>.

Index

• type Task
• type WorkerPool
  • func NewWorkPool(max int64) *WorkerPool
  • func (wp *WorkerPool) AddTask(task Task)
  • func (wp *WorkerPool) Empty() bool
  • func (wp *WorkerPool) Poll(ctx context.Context, quit chan int)
  • func (wp *WorkerPool) Top() Task

Types

type Task

type Task interface {
	UUID() string
	Run()
}

type WorkerPool

type WorkerPool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewWorkPool

func NewWorkPool(max int64) *WorkerPool

func (*WorkerPool) AddTask

func (wp *WorkerPool) AddTask(task Task)

func (*WorkerPool) Empty

func (wp *WorkerPool) Empty() bool

func (*WorkerPool) Poll

func (wp *WorkerPool) Poll(ctx context.Context, quit chan int)

func (*WorkerPool) Top

func (wp *WorkerPool) Top() Task