Download the PHP package kage3f/rux-concorrency without Composer
On this page you can find all versions of the php package kage3f/rux-concorrency. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
Download kage3f/rux-concorrency
More information about kage3f/rux-concorrency
Files in kage3f/rux-concorrency
Package rux-concorrency
Short Description A lightweight, native PHP concorrency library using Fibers
License MIT
Homepage https://github.com/kage3f/fiber-async
FAQ
Example:
In general, it is recommended to use always a project to download your libraries. In an application normally there is more than one library needed.
- Some hosting areas are not accessible by a terminal or SSH. Then it is not possible to use Composer.
- To use Composer is sometimes complicated. Especially for beginners.
- Composer needs much resources. Sometimes they are not available on a simple webspace.
- If you are using private repositories you don't need to share your credentials. You can set up everything on our site and then you provide a simple download link to your team member.
- Simplify your Composer build process. Use our own command line tool to download the vendor folder as binary. This makes your build process faster and you don't need to expose your credentials for private repositories.
Informations about the package rux-concorrency
Rux Concurrency
A lightweight, zero-dependency native PHP concurrency library built on top of Fibers (PHP 8.1+). It provides a simple async/await implementation for cooperative multitasking.
Features
- 🚀 Cooperative Multitasking: Run multiple I/O-bound tasks concurrently.
- 🛠 Simple API: Familiar
async,await, andwaitfunctions. - 📦 Zero Dependencies: Pure PHP, no extensions like
parallelorswoolerequired. - 🔌 Event Loop: Built-in scheduler with support for Timers and non-blocking I/O (Streams).
- 🌐 Robust HTTP Client: High-level
get()andget_json()with built-in support for:- SSL/TLS: Secure connections out of the box.
- Redirects: Automatically follows 301, 302, 307, and 308 redirects.
- Compression: Automatic GZIP decompression.
- Chunked Encoding: Handles chunked transfer encoding seamlessly.
- Validation: Throws detailed exceptions for non-2xx status codes or JSON failures.
Installation
Install the package via Composer:
API Documentation
This library exposes several helper functions in the Rux namespace.
Rux\async(callable $callback): Task
Starts a new asynchronous task.
- What it does: Creates a new
Taskinstance, adds it to the Scheduler, and starts its execution immediately until it hits a suspension point. - Returns: A
Taskinstance.
Rux\await(Task $task): mixed
Waits for a task to complete.
- What it does: Suspends the current fiber until the provided task is finished.
- Returns: The task's return value. Rethrows any exception occurred inside the task.
Rux\wait(): void
Runs the task scheduler.
- What it does: Starts the main loop that processes all tasks. This function is blocking and returns when all tasks are done.
Rux\sleep(int $milliseconds): void
Pauses execution without blocking the process.
- What it does: Suspends the current fiber for a set period, allowing other tasks to run.
Rux\get(string $url): string
Performs a non-blocking GET request.
- Features: Handles SSL, redirects, GZIP, and chunked encoding.
- Throws:
Exceptionon connection failure or non-2xx status codes.
Rux\get_json(string $url): array
Performs a GET request and decodes the JSON response.
- Throws:
Exceptionif the response is not a valid JSON or the request fails.
Rux\parallel_each(array $items, callable $callback, int $concurrency = 10): void
Processes an array in parallel.
- What it does: Splits the array into chunks and runs each chunk in a separate asynchronous task. Useful for bulk database inserts or processing large datasets.
Rux\parallel_map(array $items, callable $callback, int $concurrency = 10): array
Maps an array in parallel and returns the results.
- What it does: Similar to
parallel_each, but collects and returns the results from all tasks.
Usage Examples
Basic Concurrency
Parallel Processing (Database/Bulk)
Async/Await Pattern
High-Level HTTP Requests
You don't need to deal with streams manually. The library provides simple helpers:
Real-World Examples
Check the examples/ directory for professional use cases:
- Dashboard Aggregator: Simulates fetching data from multiple microservices concurrently.
- Concurrent HTTP: Demonstrates fetching multiple external URLs using the high-level
get()function.
How it works
RuxConcorrency uses PHP Fibers to pause and resume execution. When a task performs a non-blocking operation (like Rux\sleep or a non-blocking stream read), it suspends itself, allowing the Scheduler to run other pending tasks.
License
MIT License. Please see the LICENSE file for more information.
