Skip to content
This repository has been archived by the owner on Oct 31, 2023. It is now read-only.

Commit

Permalink
Merge pull request #19 from facebookresearch/v0.1
Browse files Browse the repository at this point in the history
Minor change for ParallelLoop
  • Loading branch information
xiaomengy authored Feb 11, 2022
2 parents f407c60 + 88e5dbe commit 0838539
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions rlmeta/core/loop.py
Original file line number Diff line number Diff line change
Expand Up @@ -271,6 +271,10 @@ def seed(self) -> Optional[int]:
return self._seed

def run(self) -> NoReturn:
self.start()
self.join()

def start(self) -> None:
processes = []
for loop in self._async_loops:
loop.init_launching()
Expand All @@ -280,9 +284,6 @@ def run(self) -> NoReturn:
process.start()
self._processes = processes

def start(self) -> None:
self.run()

def join(self) -> None:
for process in self._processes:
process.join()
Expand Down

0 comments on commit 0838539

Please sign in to comment.