Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- from multiprocessing import shared_memory, Process
- import time
- def print_memory(shm_name):
- shm = shared_memory.SharedMemory(name=shm_name)
- size = 1727
- t0 = time.time()
- for i in range(100000):
- bytes(shm.buf[i * size:size * (i + 1)])
- print("read elapsed: %.6fs" % (time.time() - t0))
- def main():
- shm = shared_memory.SharedMemory(create=True, size=172700000)
- print(shm.name)
- v = bytes(
- '09608585587 04leon 06soccer 06209396 161143492113251399 034Santos Fc Ica vs Deportivo Coopsol 013Santos Fc Ica 017Deportivo Coopsol 0140:0 (0:0) 1:00 048Сегунда Дивизион, Плей-офф 130https://www.leon.ru/events/Soccer/1143492094952472-Peru-Segunda-Division-Playoffs/1143492113251399-Santos-Fc-Ica-Deportivo-Coopsol 1010 015742797311574279731',
- encoding='utf-8'
- )
- size = len(v)
- print("size of data item: ", size)
- t0 = time.time()
- for i in range(100000):
- shm.buf[i * size:size * (i + 1)] = bytearray(v)
- print("write elapsed: %.6fs" % (time.time() - t0))
- p = Process(target=print_memory, args=(shm.name,))
- p.start()
- p.join()
- shm.close()
- shm.unlink()
- if __name__ == '__main__':
- main()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement