recruiterphp/concurrency

MongoDB-based locking system

v6.0.0 2025-08-08 20:29 UTC

Requires

• php: ^8.4
• ext-mongodb: *
• mongodb/mongodb: ^2.1
• recruiterphp/clock: ^5.0

Requires (Dev)

• ergebnis/composer-normalize: ^2.47
• friendsofphp/php-cs-fixer: ^3.85
• giorgiosironi/eris: ^1.0
• phake/phake: ^4.6
• phpstan/phpstan: ^2.1
• phpunit/phpunit: ^12.3
• rector/rector: ^2.1
• symfony/process: ^7.3

Replaces

• easywelfare/onebip-concurrency: v6.0.0
• onebip/onebip-concurrency: v6.0.0

MIT

• Contributors

README

A MongoDB-based locking system for PHP applications that provides distributed locking mechanisms to coordinate concurrent operations across multiple processes or servers.

Features

• Distributed Locking: MongoDB-based locks that work across multiple processes and servers
• Lock Management: Acquire, release, refresh, and wait for locks with configurable timeouts
• Retry Mechanisms: Built-in retry logic for handling transient failures
• Process Coordination: Tools for managing process leadership and coordination
• Timeout Handling: Configurable timeouts with patience mechanisms

Requirements

• PHP 8.4+
• MongoDB extension
• MongoDB server

Installation

composer require recruiterphp/concurrency

Basic Usage

Creating and Using Locks

use Recruiter\Concurrency\MongoLock;

// Create a lock instance
$lock = new MongoLock($collection, 'my-resource-id');

try {
    // Acquire lock for 5 minutes
    $lock->acquire(300);
    
    // Perform your critical operations here
    
} catch (LockNotAvailableException $e) {
    // Handle case when lock cannot be acquired
} finally {
    // Always release the lock
    $lock->release();
}

Lock Waiting

// Wait for lock to become available
$lock->wait(
    $polling = 10,           // Check every 10 seconds
    $maximumWaitingTime = 600 // Wait maximum 10 minutes
);

Lock Refresh

// Extend lock duration
$lock->refresh(600); // Extend for another 10 minutes

Core Components

Lock Interface

The main Lock interface provides:

• acquire(int $duration) - Acquire lock for specified duration
• release(bool $force) - Release the lock
• refresh(int $duration) - Extend lock duration
• wait(int $polling, int $maximumWaitingTime) - Wait for lock availability
• show() - Get diagnostic information

Implementations

• MongoLock - MongoDB-based distributed lock
• NullLock - No-op lock for testing/disabled scenarios

Utilities

• Leadership - Process leadership coordination
• Patience/TimeoutPatience - Timeout handling mechanisms
• InProcessRetry - Retry logic for operations
• PeriodicalCheck - Periodic status checking

Development

The project uses Docker for development. Available make targets:

Setup

make build          # Build Docker image
make up             # Start services
make down           # Stop services
make install        # Install dependencies
make update         # Update dependencies

Testing

make test           # Run tests (excluding long-running ones)
make test-long      # Run long-running tests only

The project includes property-based testing using Eris and traditional unit tests with PHPUnit.

Code Quality

make phpstan        # Run static analysis
make rector         # Run automated refactoring
make fix-cs         # Fix code style issues

Utilities

make shell          # Open shell in PHP container
make logs           # View container logs
make clean          # Clean up containers and volumes

Code Quality

The project maintains high code quality with:

• PHPStan - Static analysis at high levels
• PHP CS Fixer - Code style enforcement
• Rector - Automated refactoring and upgrades
• Composer Normalize - Normalized composer.json

License

MIT License. See LICENSE file for details.

Contributing

Contributions are welcome! Please ensure all tests pass and code quality checks are satisfied before submitting pull requests.