rosny is a lightweight library for building concurrent systems.
Installation
Tested on:
- Linux
- Python >= 3.6
From pip:
pip install rosny
From source:
pip install git+https://github.com/lRomul/rosny.git@master
Example
from multiprocessing import Queue
from rosny import ThreadStream, ProcessStream, ComposeStream
class SenderStream(ThreadStream): # using threading.Thread
def __init__(self, queue: Queue):
super().__init__(loop_rate=30)
self.queue = queue
self.count = 0
# run the method in a loop in a separate thread
def work(self):
self.queue.put(self.count)
self.logger.info(f'put {self.count}')
self.count += 1
class ReceiverStream(ProcessStream): # using multiprocessing.Process
def __init__(self, queue: Queue):
super().__init__()
self.queue = queue
# run the method in a loop in a separate process
def work(self):
value = self.queue.get(timeout=1)
self.logger.info(f'get {value}')
class MainStream(ComposeStream): # merging several streams
def __init__(self):
super().__init__()
queue = Queue()
self.sender = SenderStream(queue)
self.receiver = ReceiverStream(queue)
if __name__ == "__main__":
stream = MainStream()
stream.start()
stream.wait(5)
stream.stop()
stream.join()
11 Nov 27, 2022
17 Jun 26, 2022
3 May 4, 2022
20 Jan 5, 2023
5.7k Jan 1, 2023
49 Oct 9, 2022
1 Dec 11, 2021
2 Feb 4, 2022
83 Sep 23, 2022
55.9k Jan 4, 2023
212 Dec 24, 2022
1 Aug 4, 2021
23 Nov 30, 2022
2 Nov 30, 2022
20 Aug 21, 2022
12 Jul 13, 2022
31 Sep 15, 2022
30 Mar 5, 2022
2 Nov 15, 2022
2 Jan 11, 2022
102 Jan 6, 2023
5k Jan 7, 2023
12 Nov 5, 2022
16 Aug 18, 2022
8 Mar 13, 2022
573 Dec 27, 2022
2.8k Jan 5, 2023