()
| 3954 | } |
| 3955 | workers += 1; |
| 3956 | var next = function () { |
| 3957 | workers -= 1; |
| 3958 | if (task.callback) { |
| 3959 | task.callback.apply(task, arguments); |
| 3960 | } |
| 3961 | if (q.drain && q.tasks.length + workers === 0) { |
| 3962 | q.drain(); |
| 3963 | } |
| 3964 | q.process(); |
| 3965 | }; |
| 3966 | var cb = only_once(next); |
| 3967 | worker(task.data, cb); |
| 3968 | } |