mirror of
https://gitee.com/johng/gf
synced 2026-07-04 21:03:13 +08:00
32 lines
812 B
Go
32 lines
812 B
Go
// Copyright 2017 gf Author(https://gitee.com/johng/gf). All Rights Reserved.
|
|
//
|
|
// This Source Code Form is subject to the terms of the MIT License.
|
|
// If a copy of the MIT was not distributed with this file,
|
|
// You can obtain one at https://gitee.com/johng/gf.
|
|
|
|
package groutine
|
|
|
|
import (
|
|
"gitee.com/johng/gf/g/container/gset"
|
|
"gitee.com/johng/gf/g/container/glist"
|
|
)
|
|
|
|
// 创建goroutine池管理对象
|
|
func New() *Pool {
|
|
return &Pool {
|
|
queue : glist.NewSafeList(),
|
|
pjobs : gset.NewInterfaceSet(),
|
|
}
|
|
}
|
|
|
|
// 添加异步任务
|
|
func (p *Pool) Add(f func()) {
|
|
p.getJob().setJob(f)
|
|
}
|
|
|
|
// 关闭池，所有的任务将会停止，此后继续添加的任务将不会被执行
|
|
func (p *Pool) Close() {
|
|
p.pjobs.Iterator(func(v interface{}){
|
|
v.(*PoolJob).stop()
|
|
})
|
|
} |