Skip to main content

Stoppable thread with common stop signalling

Project description


======================================


.. image:: https://readthedocs.org/projects/attentive/badge/?version=latest
:target: http://attentive.readthedocs.io/en/latest/?badge=latest
:alt: Documentation Status


.. image:: https://github.com/sthysel/attentive/blob/master/docs/attentive.jpg?raw=true


.. code:: python


from attentive import StoppableThread, quit
from random import randint


class Man(StoppableThread):
def __init__(self, name):
StoppableThread.__init__(self)
self.name = name

def run(self):
print('{} has quickened'.format(self.name))
while not self.stopped:
self.sleep(randint(1, 10))
print('{} throws a {}'.format(self.name, randint(1, 6)))

print('{} expires'.format(self.name))


with Man('Trump'), Man('Wang'), Man('Erdoğan'):
while not quit.is_set():
quit.wait(1)



Example Run
***********

.. code:: bash


🚼Trump has quickened
🚼Wang has quickened
🚼Erdoğan has quickened
Wang throws a ☣
Trump throws a ☢
Erdoğan throws a ☣
Wang throws a ☣
Wang throws a ☣
Erdoğan throws a 🍭
Erdoğan throws a ☣
Trump throws a ☣
^CErdoğan throws a 🍼
☠ Erdoğan expires
Wang throws a ☣
☠ Wang expires
Trump throws a 🍼
☠ Trump expires



Use ``attentive`` if you need to wire up a some worker threads that needs to cleanly
shut themselves down on a SIG_INT or SIG_TERM.

``StoppableThread`` is a context managed thread that lives on while in context. Once it exists
context it sets its internal stopped flag that are periodically checked for state. This signals
thread state allowing the thread to cleanly exit.

External state is controlled by a signal event, exiting the main context loop.

Internally use the StoppableThread.sleep() method that is interrupted when stop()ed during
sleep.

Install
=======

Install from pypi

.. code::

$ pip install attentive

Install from source

.. code::

$ pip install .



Versioning
==========

Current version is 0.1.5


Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distributions

No source distribution files available for this release.See tutorial on generating distribution archives.

Built Distribution

attentive-0.1.5-py2.py3-none-any.whl (5.1 kB view details)

Uploaded Python 2 Python 3

File details

Details for the file attentive-0.1.5-py2.py3-none-any.whl.

File metadata

File hashes

Hashes for attentive-0.1.5-py2.py3-none-any.whl
Algorithm Hash digest
SHA256 debe72dfd915d569ec5aaa2bd0699daa91b09730de49030c0460768a7f4381bf
MD5 e95e00ef2d03dd7aa490120cb0b56ad5
BLAKE2b-256 b15f0422494cf88c5255d059897f674a6897f42b80b35a2f194852dfebcd06bd

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page