Fix wrong size increasing code.

This commit is contained in:
Marcus 2015-07-24 15:14:17 +08:00
parent 2df901b064
commit 60ab35774a

View File

@ -60,13 +60,13 @@ class AsyncPool{
public function increaseSize($newSize){ public function increaseSize($newSize){
$newSize = (int) $newSize; $newSize = (int) $newSize;
if($newSize > $this->size){ if($newSize > $this->size){
$this->size = $newSize;
for($i = $this->size; $i < $newSize; ++$i){ for($i = $this->size; $i < $newSize; ++$i){
$this->workerUsage[$i] = 0; $this->workerUsage[$i] = 0;
$this->workers[$i] = new AsyncWorker; $this->workers[$i] = new AsyncWorker;
$this->workers[$i]->setClassLoader($this->server->getLoader()); $this->workers[$i]->setClassLoader($this->server->getLoader());
$this->workers[$i]->start(); $this->workers[$i]->start();
} }
$this->size = $newSize;
} }
} }