/usr/lib/python3/dist-packages/aioprocessing/queues.py is in python3-aioprocessing 1.0.0-3.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 | import asyncio
import multiprocessing
from multiprocessing import Queue, SimpleQueue, JoinableQueue
from .executor import CoroBuilder
class AioBaseQueue(metaclass=CoroBuilder):
coroutines = ['get', 'put']
class AioSimpleQueue(AioBaseQueue):
""" An asyncio-friendly version of mp.SimpleQueue.
Provides two asyncio.coroutines: coro_get and coro_put,
which are asynchronous version of get and put, respectively.
"""
delegate = SimpleQueue
class AioQueue(AioBaseQueue):
""" An asyncio-friendly version of mp.SimpleQueue.
Provides two asyncio.coroutines: coro_get and coro_put,
which are asynchronous version of get and put, respectively.
"""
delegate = Queue
class AioJoinableQueue(AioBaseQueue):
""" An asyncio-friendly version of mp.JoinableQueue.
Provides three asyncio.coroutines: coro_get, coro_put, and
coro_join, which are asynchronous version of get put, and
join, respectively.
"""
coroutines = ['join']
delegate = JoinableQueue
|