معرفی شرکت ها

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

توضیحات

A lock-free, thread-safe queue using the C++ atomic library to synchronise memory access.

ویژگی	مقدار
سیستم عامل	-
نام فایل	atomic-queue-1.0.1
نام	atomic-queue
نسخه کتابخانه	1.0.1
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Andriy Rossoshynskyy
ایمیل نویسنده	andriy.rossoshynskyy@gmail.com
آدرس صفحه اصلی	https://github.com/arossoshynskyy/atomic-queue
آدرس اینترنتی	https://pypi.org/project/atomic-queue/
مجوز	-

# atomic-queue A thread-safe, lock-free queue implementation based on the LMAX Disruptor, with crititcal parts written in C++. This queue supports multiple producers and consumers. Producers are responsible for managing their own threads, while consumer threads are managed by the queue and are required to implement the EventHandler interface. ## Example Initialise an atomic queue instance with the buffer capacity and a wait strategy. The buffer capacity must be a power of 2 integer. ``` from atomicqueue import AtomicQueue, BUSY_SPIN_WAIT_STRATEGY queue = AtomicQueue(256, wait_strategy=BUSY_SPIN_WAIT_STRATEGY) ``` Define how the events will be consumed. In the example below event handler "h_one" and "h_two" can overrun each other but can not overrun the publishers, while event handler "h_three" can only consume events after "h_one" and "h_two" have finished consuming them. ``` queue.handle_events_with(NoOpEventHandler("h_one"), NoOpEventHandler("h_two")).then(NoOpEventHandler("h_three")) ``` Once configured the queue can be started with the following command. ``` queue.start() ``` To publish to the queue, simply call publish_event on the queue. ``` queue.publish_event(event) ``` Stop the queue by calling stop(). ``` queue.stop() ```

زبان مورد نیاز

مقدار	نام
>=3.6	Python

نحوه نصب

نصب پکیج whl atomic-queue-1.0.1:

pip install atomic-queue-1.0.1.whl

نصب پکیج tar.gz atomic-queue-1.0.1:

pip install atomic-queue-1.0.1.tar.gz