| | |
|---|
| | | def run_process_1(pipe): |
|---|
| | | tag = 'l2-000333' |
|---|
| | | with contextlib.closing(mmap.mmap(-1, 1000 * 100, tagname=tag, access=mmap.ACCESS_WRITE)) as m: |
|---|
| | | for i in range(1, 10001): |
|---|
| | | for i in range(1, 100): |
|---|
| | | start = time.time() |
|---|
| | | m.seek(0) |
|---|
| | | m.write((f"msg {i} " * 10000).encode("utf-8")) |
|---|
| | | m.write((f"msg {i} " * 1).encode("utf-8")) |
|---|
| | | m.flush() |
|---|
| | | print("耗时", time.time() - start) |
|---|
| | | time.sleep(1) |
|---|
| | |
|---|
| | | print(len(s), s) |
|---|
| | | time.sleep(1) |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | l2_data_manager.test() |
|---|
| | | pass |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__1': |
|---|
| | | p1, p2 = multiprocessing.Pipe() |
|---|
| | | serverProcess = multiprocessing.Process(target=run_process_1, args=(p1,)) |
|---|
| | | jueJinProcess = multiprocessing.Process(target=run_process_2, args=(p2,)) |
|---|
