init prject

Author: inhere

.php-cs-fixer.php

@@ -1,7 +1,7 @@
 <?php
 
 $header = <<<'EOF'
-This file is part of inherelab/php-pkg-template.
+This file is part of phppkg/taskpm.
 
 @link     https://github.com/inhere
 @author   https://github.com/inhere

README.md

@@ -1,29 +1,39 @@
 # php-pkg-template
 
-[![License](https://img.shields.io/github/license/inherelab/php-pkg-template.svg?style=flat-square)](LICENSE)
-[![Php Version](https://img.shields.io/packagist/php-v/inherelab/php-pkg-template?maxAge=2592000)](https://packagist.org/packages/inherelab/php-pkg-template)
-[![GitHub tag (latest SemVer)](https://img.shields.io/github/tag/inherelab/php-pkg-template)](https://github.com/inherelab/php-pkg-template)
-[![Actions Status](https://github.com/inherelab/php-pkg-template/workflows/Unit-Tests/badge.svg)](https://github.com/inherelab/php-pkg-template/actions)
+[![License](https://img.shields.io/github/license/phppkg/taskpm.svg?style=flat-square)](LICENSE)
+[![Php Version](https://img.shields.io/packagist/php-v/phppkg/taskpm?maxAge=2592000)](https://packagist.org/packages/phppkg/taskpm)
+[![GitHub tag (latest SemVer)](https://img.shields.io/github/tag/phppkg/taskpm)](https://github.com/phppkg/taskpm)
+[![Actions Status](https://github.com/phppkg/taskpm/workflows/Unit-Tests/badge.svg)](https://github.com/phppkg/taskpm/actions)
 
-TODO: package_description
+Run multi tasks by PHP multi process
 
 ## Install
 
 **composer**
 
 ```bash
-composer require inherelab/php-pkg-template
+composer require phppkg/taskpm
 ```
 
 ## Usage
 
 - github: `use the template` for quick create project
 - clone this repository to local
 - search `package_description` and replace your package description
-- search all `inherelab/php-pkg-template` and replace to your package name.
+- search all `phppkg/taskpm` and replace to your package name.
   - contains all words like `InhereLab\DemoPkg`
 - update `composer.json` contents, field: name, description, require, autoload
 
+## Refers
+
+- https://github.com/upfor/forkman
+  - https://github.com/SegmentFault/SimpleFork
+- https://github.com/huyanping/simple-fork-php
+- https://github.com/Arara/Process
+- https://github.com/bouiboui/spawn
+- https://github.com/symplely/processor
+- https://github.com/symplely/coroutine
+
 ## License
 
 [MIT](LICENSE)

composer.json

@@ -1,9 +1,9 @@
 {
-  "name": "inherelab/php-pkg-template",
-  "description": "TODO: package description",
+  "name": "phppkg/taskpm",
+  "description": "Run multi tasks by PHP multi process",
   "type": "library",
   "license": "MIT",
-  "homepage": "https://github.com/inherelab/php-pkg-template",
+  "homepage": "https://github.com/phppkg/taskpm",
   "keywords": [
     "library",
     "tool"
@@ -15,18 +15,17 @@
     }
   ],
   "require": {
-    "php": ">7.4.0",
-    "ext-mbstring": "*",
-    "toolkit/stdlib":"~1.0"
+    "php": ">8.0.0",
+    "toolkit/sys-utils":"~2.0"
   },
   "autoload": {
     "psr-4": {
-      "InhereLab\\DemoPkg\\": "src/"
+      "PhpPkg/TaskPM\\": "src/"
     }
   },
   "autoload-dev": {
     "psr-4": {
-      "InhereLab\\DemoPkgTest\\": "test/"
+      "PhpPkg/TaskPMTest\\": "test/"
     }
   },
   "bin": [

example/demo.php

@@ -1,13 +1,14 @@
 <?php
 
-use PhpComLab\CliMarkdown\CliMarkdown;
+use PhpPkg\TaskPM\TaskManager;
 
-require dirname(__DIR__) . '/vendor/autoload.php';
+require dirname(__DIR__) . '/test/bootstrap.php';
 
-$contents = file_get_contents(dirname(__DIR__) . '/README.md');
-$praser = new CliMarkdown;
+TaskManager::new()
+    ->onMaster(function () {
 
-$rendered = $praser->render($contents);
-
-echo $rendered;
+    })
+    ->onWorker(function () {
 
+    })
+    ->wait();

example/map-reduce.php

@@ -0,0 +1,30 @@
+<?php
+
+use PhpPkg\TaskPM\TaskManager;
+
+require dirname(__DIR__) . '/test/bootstrap.php';
+
+// run: php example/map-reduce.php
+TaskManager::new()
+    ->onMaster(function (TaskManager $mgr) {
+        $mgr->submit([1, 1000]);
+
+        sleep(3);
+        $mgr->submit([1001, 2000]);
+
+        sleep(3);
+        $mgr->submit([2001, 3000], function ($data, TaskManager $mgr) {
+            $mgr->log('submit 3', ['ctx' => $data]);
+
+            sleep(3);
+            $mgr->submit([3001, 4000]);
+        });
+
+        // $mgr->wait(3000);
+    })
+    ->onWorker(function ($params, TaskManager $mgr) {
+        // slave process's callback cannot print anything, print log please use $fm->log()
+        $mgr->log('on slave', $params);
+        return $params;
+    })
+    ->wait(3000);

src/.keep

@@ -0,0 +1,8 @@
+<?php declare(strict_types=1);
+
+namespace PhpPkg\TaskPM;
+
+class TaskContext
+{
+
+}