fixed the limited issue

This commit is contained in:
mikespook 2012-06-04 16:34:29 +08:00
parent 6d68430f75
commit a142bcff58

View File

@ -259,11 +259,11 @@ func (worker *Worker) exec(job *Job) (err error) {
}
var result []byte
if worker.limit != nil {
select {
case <-worker.limit:
defer func() {
worker.limit <- true
}()
select {
case <-worker.limit:
case <-time.After(time.Second * time.Duration(f.timeout)):
err = common.Errorf("The function was executed timeout: %s", funcname)
}