Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LimitTaskManager ¶
type LimitTaskManager struct {
RequireChan chan bool
DoChan chan bool
FinishChan chan bool
MaxThreadNumber,
TotalTaskCount int
ActiveCount,
WaitingCount,
FinishedCount int
AllTaskFinishedChan chan bool
}
func NewLimitTaskManager ¶
func NewLimitTaskManager(maxThreadNumber, totalTaskCount int) *LimitTaskManager
type UnlimitTaskManager ¶
type UnlimitTaskManager struct {
DemandChan chan struct{} //要求进行任务
DoChan chan bool //若为false, 所有任务完成
TaskFinishesChan chan struct{} //汇报任务完成
AllTasksFinishChan chan struct{} //汇报所有任务完成
IsAllTasksFinished bool
MaxThreadNumber int
ActiveCount,
WaitingCount int
WaitForFinishChan chan struct{} //阻塞直至所有任务完成
}
func NewUnlimitTaskManager ¶
func NewUnlimitTaskManager(maxThreadNumber int) *UnlimitTaskManager
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.