kbuffthreadpool

README

kbuffthreadpool协程池

说明

• 使用buff做任务队列的协程池
• 每个协程仅从自身任务队列中取任务，这样可以减少锁的争抢
• 每个任务可分配至最少任务的队列中，也可根据任务key值分配到相同的任务池，以此来保证任务的严格串行

Documentation

Overview

Package kbuffthreadpool 协程池

说明 使用buff做任务队列的协程池 每个协程仅从自身任务队列中取任务，这样可以减少锁的争抢 每个任务可分配至最少任务的队列中，也可根据任务key值分配到相同的任务池，以此来保证任务的严格串行

Index

• type PoolHandlerIF
• type PoolStatus
• type Task
  • func NewTask() *Task
• type TaskJobIF
• type ThreadPool
  • func NewThreadPool(num uint, cb PoolHandlerIF) (*ThreadPool, error)
  • func (tp *ThreadPool) AddTaskByKey(elem *Task) error
  • func (tp *ThreadPool) AddTaskByMini(elem *Task) error
  • func (tp *ThreadPool) GetTaskInfo() string
  • func (tp *ThreadPool) GetTaskSize() int
  • func (tp *ThreadPool) Start() error
  • func (tp *ThreadPool) Stop() error

Types

type PoolHandlerIF

type PoolHandlerIF interface {
	OnError(msg string)
	OnEvent(msg string)
}

PoolHandlerIF handler for upper apps

type PoolStatus

type PoolStatus int

PoolStatus pool status

const (
	// PoolStatusClosed closed
	PoolStatusClosed PoolStatus = 0
	// PoolStatusInitialized initialized
	PoolStatusInitialized PoolStatus = 1
	// PoolStatusStarting starting
	PoolStatusStarting PoolStatus = 2
	// PoolStatusRunning running
	PoolStatusRunning PoolStatus = 3
	// PoolStatusStopping stopping
	PoolStatusStopping PoolStatus = 4
)

type Task

type Task struct {
	Data TaskJobIF
	Key  uint // key value for serial job
}

Task task for thread pool

func NewTask

func NewTask() *Task

NewTask new task object

type TaskJobIF

type TaskJobIF interface {
	Do(threadID uint)
}

TaskJobIF job interface

type ThreadPool

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

ThreadPool thread pool

func NewThreadPool

func NewThreadPool(num uint, cb PoolHandlerIF) (*ThreadPool, error)

NewThreadPool new thread pool

func (*ThreadPool) AddTaskByKey

func (tp *ThreadPool) AddTaskByKey(elem *Task) error

AddTaskByKey add task

func (*ThreadPool) AddTaskByMini

func (tp *ThreadPool) AddTaskByMini(elem *Task) error

AddTaskByMini add task

func (*ThreadPool) GetTaskInfo

func (tp *ThreadPool) GetTaskInfo() string

GetTaskInfo task info

func (*ThreadPool) GetTaskSize

func (tp *ThreadPool) GetTaskSize() int

GetTaskSize task size

func (*ThreadPool) Start

func (tp *ThreadPool) Start() error

Start start

func (*ThreadPool) Stop

func (tp *ThreadPool) Stop() error

Stop stop