AsyncPQ

A little exercise in concurrency. Super intuitive way to schedule asynchronous tasks with little overhead.

This library was originally being built for the Trinitum Trading Architecture to communicate with a RethinkDB Instance and update the user's capital information every tick. But I think the idea is general enough to warrant a library of it's own.

Installation

pip3 install AsyncPQ

Documentation

Example:

import asyncio
from AsyncPQ import AsyncPriorityQueue, AsyncReadWriteQueue

class TestClass(object):
	
	def __init__(self): pass

	async def testFunc(self, arg): 
		await asyncio.sleep(0)
		print(arg)

async def testFunc2(arg): 
	await asyncio.sleep(0)
	print(arg)

classDict = {'test': TestClass()}

aspq = AsyncPriorityQueue(classDict)
aspq.addTask(15, testFunc2, 15)
aspq.addTask(15, testFunc2, 15)
aspq.addTask(27, testFunc2, 27)
aspq.addTask(27, testFunc2, 27)
aspq.addTask(89, testFunc2, 89)
aspq.addTask(91, testFunc2, 91)
aspq.addClassTask(96, 'test', 'testFunc', 96)
aspq.addClassTask(99, 'test', 'testFunc', 99)
aspq.processTasks()
print()

asrwq = AsyncReadWriteQueue(classDict)
asrwq.read(testFunc2, 15)
asrwq.write(testFunc2, 15)
asrwq.read(testFunc2, 27)
asrwq.read(testFunc2, 27)
asrwq.write(testFunc2, 89)
asrwq.write(testFunc2, 91)
asrwq.cdRead('test', 'testFunc', 94)
asrwq.cdWrite('test', 'testFunc', 97)
asrwq.processTasks()

...

Terminal Outputs:

99
96
91
89
27
27
15
15

97
91
89
15
94
27
27
15

Use Cases

TBD

TODO

• PyPI support (pip install...)
• Better Documentation!