mirror of
https://github.com/semaphoreui/semaphore.git
synced 2024-11-25 06:15:56 +01:00
52 lines
716 B
Go
52 lines
716 B
Go
package tasks
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
)
|
|
|
|
type taskPool struct {
|
|
queue []*task
|
|
register chan *task
|
|
running *task
|
|
}
|
|
|
|
var pool = taskPool{
|
|
queue: make([]*task, 0),
|
|
register: make(chan *task),
|
|
running: nil,
|
|
}
|
|
|
|
func (p *taskPool) run() {
|
|
ticker := time.NewTicker(10 * time.Second)
|
|
|
|
defer func() {
|
|
ticker.Stop()
|
|
}()
|
|
|
|
for {
|
|
select {
|
|
case task := <-p.register:
|
|
fmt.Println(task)
|
|
if p.running == nil {
|
|
go task.run()
|
|
continue
|
|
}
|
|
|
|
p.queue = append(p.queue, task)
|
|
case <-ticker.C:
|
|
if len(p.queue) == 0 || p.running != nil {
|
|
continue
|
|
}
|
|
|
|
fmt.Println("Running a task.")
|
|
go pool.queue[0].run()
|
|
pool.queue = pool.queue[1:]
|
|
}
|
|
}
|
|
}
|
|
|
|
func StartRunner() {
|
|
pool.run()
|
|
}
|