| 53 | measured.wait() |
| 54 | |
| 55 | def extra_memory_child(ready: synchronize.Barrier, measured: synchronize.Barrier) -> None: |
| 56 | memory = SharedMemory(size=extra_memory_size, create=True) |
| 57 | assert memory.buf is not None |
| 58 | memory.buf[:] = bytearray([255 for _ in range(extra_memory_size)]) |
| 59 | print(f'Using the memory... {memory.buf[-1]}') |
| 60 | ready.wait() |
| 61 | measured.wait() |
| 62 | memory.close() |
| 63 | memory.unlink() |
| 64 | |
| 65 | def shared_extra_memory_child( |
| 66 | ready: synchronize.Barrier, measured: synchronize.Barrier, memory: SharedMemory |