(self, maxsize: int = 0, actor_options: Optional[Dict] = None)
| 53 | """ |
| 54 | |
| 55 | def __init__(self, maxsize: int = 0, actor_options: Optional[Dict] = None) -> None: |
| 56 | from ray._common.usage.usage_lib import record_library_usage |
| 57 | |
| 58 | record_library_usage("util.Queue") |
| 59 | |
| 60 | actor_options = actor_options or {} |
| 61 | self.maxsize = maxsize |
| 62 | self.actor = ( |
| 63 | ray.remote(_QueueActor).options(**actor_options).remote(self.maxsize) |
| 64 | ) |
| 65 | |
| 66 | def __len__(self) -> int: |
| 67 | return self.size() |
nothing calls this directly
no test coverage detected