PHPackages                             fhylabs/asyncio - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [Utility & Helpers](/categories/utility)
4. /
5. fhylabs/asyncio

ActiveLibrary[Utility & Helpers](/categories/utility)

fhylabs/asyncio
===============

PHP Asynchronous I/O Library

v1.0.1(8mo ago)19MITPHPPHP >=8.1

Since Sep 7Pushed 8mo agoCompare

[ Source](https://github.com/fitri-hy/asyncio)[ Packagist](https://packagist.org/packages/fhylabs/asyncio)[ RSS](/packages/fhylabs-asyncio/feed)WikiDiscussions main Synced 1mo ago

READMEChangelogDependenciesVersions (3)Used By (0)

 [![icon.png](./examples/icon.png)](./examples/icon.png)

AsyncIO – PHP Asynchronous I/O Library
======================================

[](#asyncio--php-asynchronous-io-library)

AsyncIO provides a modern way to run **non-blocking tasks** in PHP, including file I/O, HTTP requests, database queries, worker pools, timers, promises, and more.

---

📦 Key Features
--------------

[](#-key-features)

ModuleFunction / Description**Async**Core engine for running async tasks. Handles scheduling, hooks, and error handling.**Task**Wrapper for creating async tasks with name, priority, and cancellation.**File**Async file I/O: read, write, append, stream, and file watcher.**Worker**Worker pool for CPU-bound parallel tasks, including scheduler.**Timer**Async `setTimeout` & `setInterval` with callback.**Utils**Helper functions such as `asyncMap`, `asyncFilter`, etc.**Promise**Promise-style chaining: `then`, `catch`, `all`, `race`, `any`, `resolveNow`.**Http**Async HTTP requests (`requestAsync`) + Promise-based CRUD support, hooks before/after.**DB**Async database queries (MySQL, PostgreSQL, SQLite, etc.).**Logger**Centralized logging system with support for info, error, and debug levels.---

🚀 Requirements
--------------

[](#-requirements)

- PHP 8.1+
- Composer

---

📥 Installation
--------------

[](#-installation)

```
composer require fhylabs/asyncio
```

---

⚡ Usage & Best Practices
----------------------------

[](#-usage--best-practices)

### 1. Async – Core Engine

[](#1-async--core-engine)

```
use AsyncIO\Async;
use AsyncIO\Logger;

Async::add(fn()=> Logger::log("[Async] Task executed"));
Async::run(); // Run all async tasks
```

- Use `Async::add()` to add tasks.
- Use generators for coroutine-style tasks if necessary.

---

### 2. Task – Named & Prioritized

[](#2-task--named--prioritized)

```
use AsyncIO\Task;
use AsyncIO\Async;
use AsyncIO\Timer;
use AsyncIO\Logger;

$task = new Task(function(){
    Logger::log("[Task] Start...");
    Timer::setTimeout(5000, fn()=> Logger::log("[Task] Finish after 5s"));
}, "singleTask", 1);

Async::add($task->callable);
```

- Priority determines execution order.
- Tasks can be canceled with `$task->cancel()`.

---

### 3. Worker – CPU-bound Tasks

[](#3-worker--cpu-bound-tasks)

```
use AsyncIO\Worker;
use AsyncIO\Logger;

Worker::setConcurrency(3);

Worker::add(fn()=> Logger::log("[Worker] CPU task completed"));
Worker::schedule(fn()=> Logger::log("[Scheduler] Periodic tasks"), 5000);

Worker::runQueue(); // Run CPU-bound tasks
```

- Use Worker for heavy tasks to keep the async loop non-blocking.

---

### 4. Timer – Delay & Interval

[](#4-timer--delay--interval)

```
use AsyncIO\Timer;
use AsyncIO\Logger;

Timer::setTimeout(2000, fn()=> Logger::log("[Timer] 2 seconds passed"));
Timer::setInterval(5000, fn()=> Logger::log("[Interval] Every 5 seconds"));
```

- Non-blocking delays and intervals.

---

### 5. File – Async File I/O

[](#5-file--async-file-io)

```
use AsyncIO\File;
use AsyncIO\Logger;

File::readAsync("file.txt", fn($c)=> Logger::log($c));
File::appendAsync("file.txt", "\nAdd line", fn($ok)=> Logger::log($ok ? "Append OK" : "Failed"));
File::readStreamAsync("file.txt", fn($chunk)=> Logger::log("[Stream] Chunk size: ".strlen($chunk)));
File::watchFile("file.txt", fn($p)=> Logger::log("File changed: $p"));
```

---

### 6. Http – Async & Promise-based CRUD

[](#6-http--async--promise-based-crud)

```
use AsyncIO\Http;
use AsyncIO\Async;
use AsyncIO\Logger;

// Hooks
Async::addHook('before', fn($t)=> Logger::log("[Hook Before] HTTP task"));
Async::addHook('after', fn($t)=> Logger::log("[Hook After] HTTP task"));

// Promise CRUD Example
Async::add(function(){
    Http::requestPromise(
        ['https://jsonplaceholder.typicode.com/posts'],
        ['method'=>'POST','headers'=>['Content-Type: application/json'],'body'=>json_encode(['title'=>'foo','body'=>'bar','userId'=>1])]
    )
    ->then(fn($res)=> Logger::log("[POST] ".substr(current($res),0,50)))
    ->then(fn($res)=> Http::requestPromise(['https://jsonplaceholder.typicode.com/posts/1'], ['method'=>'GET']))
    ->then(fn($res)=> Logger::log("[GET] ".substr(current($res),0,50)))
    ->then(fn($res)=> Http::requestPromise(['https://jsonplaceholder.typicode.com/posts/1'], ['method'=>'PUT','headers'=>['Content-Type: application/json'],'body'=>json_encode(['id'=>1,'title'=>'updated','body'=>'updated','userId'=>1])]))
    ->then(fn($res)=> Logger::log("[PUT] ".substr(current($res),0,50)))
    ->then(fn($res)=> Http::requestPromise(['https://jsonplaceholder.typicode.com/posts/1'], ['method'=>'DELETE']))
    ->then(fn($res)=> Logger::log("[DELETE] Done"))
    ->catch(fn($e)=> Logger::log("[HTTP Error] ".$e->getMessage()));
});
```

---

### 7. DB – Async Queries

[](#7-db--async-queries)

```
use AsyncIO\DB;
use AsyncIO\Logger;

class MyDB extends DB {
    public function __construct(){ parent::__construct("mysql:host=127.0.0.1;dbname=demo","root",""); }
}

$db = new MyDB();
$db->queryAsync("SELECT id,name FROM users LIMIT 3", fn($res)=>{
    foreach($res as $row) Logger::log("[DB] {$row['id']} - {$row['name']}");
});
```

- Non-blocking database queries.

---

### 8. Utils – Async Map

[](#8-utils--async-map)

```
use AsyncIO\Utils;
use AsyncIO\Logger;

Utils::asyncMap([1,2,3], fn($n,$done)=> $done($n*2), fn($res)=> Logger::log("[Utils] Doubled: ".implode(",",$res)));
```

---

### 9. Promise – Chaining, All, Race

[](#9-promise--chaining-all-race)

```
use AsyncIO\Promise;
use AsyncIO\Timer;
use AsyncIO\Logger;

$p1 = new Promise(fn($resolve,$reject)=> Timer::setTimeout(1000, fn()=> $resolve("1")));
$p2 = new Promise(fn($resolve,$reject)=> Timer::setTimeout(2000, fn()=> $resolve("2")));

Promise::all([$p1,$p2], fn($res)=> Logger::log("[All] ".implode(",",$res)));
Promise::race([$p1,$p2], fn($winner)=> Logger::log("[Race] $winner"));
```

---

### 10. Logger – Centralized Logging

[](#10-logger--centralized-logging)

```
use AsyncIO\Logger;

Logger::log("[INFO] Standard log messages");
```

---

### 🔹 Best Practices

[](#-best-practices)

- Add all tasks before `Async::run()`.
- Use `Worker` for CPU-bound tasks to keep the async loop non-blocking.
- Use `Timer` for delays or intervals.
- Use `Task` with priority for important tasks.
- Use `before` & `after` hooks for HTTP or other async tasks.
- Logger ensures consistent output and debugging.

---

⚡ Project Structure
-------------------

[](#-project-structure)

```
AsyncIO/
│
├─ src/
│   ├─ Async.php
│   ├─ Task.php
│   ├─ File.php
│   ├─ Worker.php
│   ├─ Timer.php
│   ├─ Utils.php
│   ├─ Promise.php
│   ├─ Http.php
│   ├─ DB.php
│   └─ Logger.php
│
├─ examples/
│   ├─ example.php
│   └─ data/
│       └─ sample.txt
│
├─ composer.json
└─ vendor/  (composer dependencies)

```

 [![diagram.png](./examples/diagram.png)](./examples/diagram.png)

###  Health Score

31

—

LowBetter than 68% of packages

Maintenance60

Regular maintenance activity

Popularity6

Limited adoption so far

Community6

Small or concentrated contributor base

Maturity45

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 100% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~0 days

Total

2

Last Release

253d ago

### Community

Maintainers

![](https://www.gravatar.com/avatar/1f07f5c88a83067cc5d2421cd9a1066babd8b40b27879a1d709c90e280498755?d=identicon)[fitri-hy](/maintainers/fitri-hy)

---

Top Contributors

[![fitri-hy](https://avatars.githubusercontent.com/u/155282015?v=4)](https://github.com/fitri-hy "fitri-hy (8 commits)")

---

Tags

asynchronoushttp-requestsnon-blockingphppromiseworker

### Embed Badge

![Health badge](/badges/fhylabs-asyncio/health.svg)

```
[![Health](https://phpackages.com/badges/fhylabs-asyncio/health.svg)](https://phpackages.com/packages/fhylabs-asyncio)
```

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)