调整 位置
parent
30312d4b9c
commit
b6be235c6e
|
@ -52,10 +52,10 @@ func (t *TaskMan) preRun(cf *changedFile) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
go t.run(cf)
|
go t.run(cf)
|
||||||
|
go t.notifier.Put(cf)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *TaskMan) run(cf *changedFile) {
|
func (t *TaskMan) run(cf *changedFile) {
|
||||||
go t.notifier.Put(cf)
|
|
||||||
t.runLock.Lock()
|
t.runLock.Lock()
|
||||||
defer t.runLock.Unlock()
|
defer t.runLock.Unlock()
|
||||||
for i := 0; i < len(cfg.Command.Exec); i++ {
|
for i := 0; i < len(cfg.Command.Exec); i++ {
|
||||||
|
|
Loading…
Reference in New Issue