Changeset View
Changeset View
Standalone View
Standalone View
src/repository/graph/query/ArcanistGitCommitGraphQuery.php
| Show First 20 Lines • Show All 98 Lines • ▼ Show 20 Lines | while ($this->futures || $this->iterators) { | ||||
| $iterator_limit = 8; | $iterator_limit = 8; | ||||
| while (count($this->iterators) < $iterator_limit) { | while (count($this->iterators) < $iterator_limit) { | ||||
| if (!$this->futures) { | if (!$this->futures) { | ||||
| break; | break; | ||||
| } | } | ||||
| $future = array_pop($this->futures); | $future = array_pop($this->futures); | ||||
| $future->startFuture(); | $future->start(); | ||||
| $iterator = id(new LinesOfALargeExecFuture($future)) | $iterator = id(new LinesOfALargeExecFuture($future)) | ||||
| ->setDelimiter("\1"); | ->setDelimiter("\1"); | ||||
| $iterator->rewind(); | $iterator->rewind(); | ||||
| $iterator_key = $this->getNextIteratorKey(); | $iterator_key = $this->getNextIteratorKey(); | ||||
| $this->iterators[$iterator_key] = $iterator; | $this->iterators[$iterator_key] = $iterator; | ||||
| } | } | ||||
| ▲ Show 20 Lines • Show All 94 Lines • Show Last 20 Lines | |||||