Lightweight library for building concurrent systems
MIT License
Bot releases are hidden (Show)
Full Changelog: https://github.com/lRomul/rosny/compare/v0.0.6...v0.1.0
Published by lRomul about 2 years ago
work_loop
method to loop
.on_work_loop_begin
callback method to on_loop_begin
.on_work_loop_end
callback method to on_loop_end
.Published by lRomul over 3 years ago
profile_interval
of ThreadStream
and ProcessStream
.ProcessStream
now works with any methods to start a process: spawn
, fork
, and forkserver
. User should use multiprocessing.set_start_method()
function before starting streams.on_compile_begin
, on_compile_end
, on_work_loop_begin
, on_work_loop_end
.common_state
and can be set by user via compile method.handle_signals
parameter of compile method. A boolean value indicating whether handling systems signals.on_wait_begin
, on_wait_end
.Published by lRomul over 3 years ago
rosny.process.ProcessStream
like ThreadStream
runs a task in a loop with the ability to set the loop frequency but in a separate process.rosny.signal
- set of functions for handling system signals (SIGINT, SIGTERM, SIGQUIT).rosny.timing.LoopRateManager
limits rate of a loop.daemon
parameter for ThreadStream
/ProcessStream
indicating whether thread/process will a daemon or not.Published by lRomul over 3 years ago
compiled
, stopped
, joined
predicate methods of streams.rosny.thread.ThreadStream
: make rate_manager
as a public attribute.Published by lRomul over 3 years ago
rosny is a simple library for building concurrency systems.
rosny.thread.ThreadStream
runs a task in a loop with the ability to set the loop frequency.rosny.compose.ComposeStream
orchestrates several streams.rosny.timing.LoopRateManager
limits rate of a loop.