What's Changed

• Fixed posix semaphore blocking thread when there is no space left on device by @azjezz in #29
• Added a buffer size parameter to createChannelPair() to specify a number of items which may be buffered in memory before back pressure is applied.

New Contributors

• @azjezz made their first contribution in #29

Full Changelog: v2.2.0...v2.3.0

2.3.0 Latest

Latest

Compare

Choose a tag to compare

What's Changed

• Add PriorityQueue by @trowski in #27

Full Changelog: v2.1.0...v2.2.0

2.2.0

Compare

Choose a tag to compare

What's Changed

• Added re-entry support to synchronized() by @kelunik in #26
• Fixed error handling in SharedMemoryParcel
• Fixed a typo by @thgs in #25

New Contributors

• @thgs made their first contribution in #25

Full Changelog: v2.0.0...v2.1.0

2.1.0

Compare

Choose a tag to compare

• PHP 8.1 now required.
• Channel now extends Amp\Closable, which adds an onClose() method to attach a closure that is invoked when the channel closes.

This release moves Channel and Parcel interfaces from amphp/parallel to this library.

• Channel allows two way communicate between execution contexts, such as two coroutines or two processes.
• Parcel allows sharing a value across execution contexts, with mutually-exclusive access to modifying that value using Parcel::synchronized().

• Add compatibility with Revolt v1.x

• Update to revolt/event-loop v0.2.x (#20)

Note: This is a pre-release, there might be breaking changes in the final stable version.

• Major release avoiding promises in favor of fibers supported by Revolt
• ConcurrentIterator functions have been removed and will be available as operators in amphp/pipeline
• FileMutex has been removed, as a better implementation ships as part of amphp/file
• Removed ThreadedMutex and ThreadedSemaphore
• Removed Lock::getId()
• Barrier::await supports cancellation now
• synchronized accepts any Semaphore now instead of a Mutex only

Stable release compatible with AMPHP v3 and fibers! 🎉

As with other libraries compatible with AMPHP v3, most cases of parameters or returns of Promise<ResolutionType> have been replaced with ResolutionType.

Changes from 1.x

• ConcurrentIterator functions have been removed are now available as methods on Pipeline in amphp/pipeline
• FileMutex has been removed, as a better implementation ships as part of amphp/file
• Removed ThreadedMutex and ThreadedSemaphore
• Removed Lock::getId()
• Barrier::await supports cancellation now
• synchronized accepts any Semaphore now instead of a Mutex only
• Added Channel from amphp/parallel, which allows two way communicate between execution contexts, such as two coroutines or two processes. Channel has been modified to extend Closable
• Also added Parcel from amphp/parallel, which allows sharing a value across execution contexts with mutually-exclusive access to modifying that value using Parcel::synchronized().
• Added createChannelPair() function which returns a pair of connected Channel objects.
• Added RateLimitingSemaphore which releases locks after a given time elapses.
• Added StaticKeySemaphore, analogous to StaticKeyMutex

Changes from 2.0.0 Beta 6

• Added RateLimitingSemaphore which releases locks after a given time elapses.
• Added StaticKeySemaphore, analogous to StaticKeyMutex

• Fixed return type of createChannelPair() to use the interface
• Fixed close of channels returned from createChannelPair()
• Release locks synchronously instead of asynchronously on explicit release() calls

2.0.0

Compare

Choose a tag to compare