Method join

python/ray/tests/test_worker_capping.py:159–162

(self)

            self.limit = limit

        async def join(self):
            self.i += 1
            while self.i < self.limit:
                await asyncio.sleep(1)

    b = Barrier.remote(num_tasks)