The highest tagged major version is
v3.
package
Version:
v1.6.17
Opens a new window with list of versions in this module.
Published: Jun 3, 2021
License: Apache-2.0
Opens a new window with license information.
Imports: 4
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
func Run(maxCapacity, maxThread int)
Run 运行start running queue，指定缓冲区数和工作线程数
func RunListQueue(maxThread int)
RunListQueue 启动运行列表队列，指定工作线程数
type Jober interface {
Job()
}
Jober 是一个可以执行的异步任务
func NewJob(v interface{}, fn func(interface{})) Jober
NewJob 创建一个异步任务
type ListQueue struct {
}
ListQueue 是一个列表任务队列，用于在高并发情况下缓解服务器压力并改进任务处理
NewListQueue 创建一个列表队列，指定工作线程的数量
func NewListQueueWithMaxLen(maxThread, maxLen int) *ListQueue
NewListQueueWithMaxLen 创建一个列表队列，指定工作线程数和最大元素数
Queue 任务队列排队以在高并发情况下减轻服务器压力并改进任务处理
func NewQueue(maxCapacity, maxThread int) *Queue
NewQueue 创建一个队列，指定缓冲区数和工作线程数
func (q *Queue) Terminate()
Terminate 终止队列以接收任务并释放资源
type Queuer interface {
Run()
Push(job Jober)
Terminate()
}
Queuer 是一个任务队列，用于在高并发情况下缓解服务器压力并改进任务处理
type SyncJober interface {
Jober
Wait() <-chan interface{}
Error() error
}
SyncJober 可以执行的同步任务
func NewSyncJob(v interface{}, fn func(interface{}) (interface{}, error)) SyncJober
NewSyncJob 创建同步任务
Source Files
¶
Click to show internal directories.
Click to hide internal directories.
