Fork

The example shows how two tasks could be executed in parallel.

Internally, by default the engine still executes tasks one by one because of the nature of PHP. The tasks could be done in parallel for real if an async transition implementation is provided. A solution could use message queue (MQ) or process forking in background.

Setup


mkdir ~/pvm-fork
cd ~/pvm-fork
composer req formapro/pvm:0.4.x-dev makasim/values:0.5.x-dev

# create such file with the code below
php fork.php

Result

fork.php

purchase_order
send_email
send_sms

fork.php


<?php
use Formapro\Pvm\DefaultBehaviorRegistry;
use Formapro\Pvm\ProcessEngine;
use Formapro\Pvm\Token;
use Formapro\Pvm\ProcessBuilder;

require_once __DIR__.'/vendor/autoload.php';

$process = (new ProcessBuilder())
    ->createNode('purchase_order', 'print_label')->end()
    ->createNode('send_email', 'print_label')->end()
    ->createNode('send_sms', 'print_label')->end()

    ->createTransition('purchase_order', 'send_email')->end()
    ->createTransition('purchase_order', 'send_sms')->end()
    ->createStartTransition('purchase_order')->end()

    ->getProcess()
;

$engine = new ProcessEngine(new DefaultBehaviorRegistry([
    'print_label' => function(Token $token) {
        echo $token->getTo()->getId().PHP_EOL;
    },
]));

$token = $engine->createTokenFor($process->getStartTransition());
$engine->proceed($token);



{
    "schema": "http:\/\/pvm.forma-pro.com\/schemas\/Process.json",
    "id": "462aa555-4ad1-4796-99cc-4f328cf87b91",
    "nodes": {
        "purchase_order": {
            "schema": "http:\/\/pvm.forma-pro.com\/schemas\/Node.json",
            "id": "purchase_order",
            "behavior": "print_label"
        },
        "send_email": {
            "schema": "http:\/\/pvm.forma-pro.com\/schemas\/Node.json",
            "id": "send_email",
            "behavior": "print_label"
        },
        "send_sms": {
            "schema": "http:\/\/pvm.forma-pro.com\/schemas\/Node.json",
            "id": "send_sms",
            "behavior": "print_label"
        }
    },
    "transitions": {
        "6d3ce293-a8aa-4f2b-9148-8d3d7fd5b2e9": {
            "id": "6d3ce293-a8aa-4f2b-9148-8d3d7fd5b2e9",
            "weight": 1,
            "async": false,
            "active": true,
            "schema": "http:\/\/pvm.forma-pro.com\/schemas\/Transition.json",
            "from": "purchase_order",
            "to": "send_email"
        },
        "ecd164ca-9088-4ada-a9e8-0a7124a331c8": {
            "id": "ecd164ca-9088-4ada-a9e8-0a7124a331c8",
            "weight": 1,
            "async": false,
            "active": true,
            "schema": "http:\/\/pvm.forma-pro.com\/schemas\/Transition.json",
            "from": "purchase_order",
            "to": "send_sms"
        },
        "c0ae0bdf-3c49-4ce7-a140-9d6b33f2c90e": {
            "id": "c0ae0bdf-3c49-4ce7-a140-9d6b33f2c90e",
            "weight": 1,
            "async": false,
            "active": true,
            "schema": "http:\/\/pvm.forma-pro.com\/schemas\/Transition.json",
            "to": "purchase_order"
        }
    },
    "outTransitions": {
        "purchase_order": [
            "6d3ce293-a8aa-4f2b-9148-8d3d7fd5b2e9",
            "ecd164ca-9088-4ada-a9e8-0a7124a331c8"
        ]
    },
    "inTransitions": {
        "send_email": [
            "6d3ce293-a8aa-4f2b-9148-8d3d7fd5b2e9"
        ],
        "send_sms": [
            "ecd164ca-9088-4ada-a9e8-0a7124a331c8"
        ],
        "purchase_order": [
            "c0ae0bdf-3c49-4ce7-a140-9d6b33f2c90e"
        ]
    },
    "tokens": {
        "771f8a2f-b4da-4c47-89a3-4c44bdcda5c2": {
            "schema": "http:\/\/pvm.forma-pro.com\/schemas\/Token.json",
            "id": "771f8a2f-b4da-4c47-89a3-4c44bdcda5c2",
            "transitions": [
                {
                    "schema": "http:\/\/pvm.forma-pro.com\/schemas\/TokenTransition.json",
                    "id": "43be34d3-4a7a-402e-87f5-54752867fbab",
                    "transitionId": "c0ae0bdf-3c49-4ce7-a140-9d6b33f2c90e",
                    "weight": 1,
                    "state": "opened",
                    "time": 16031629833237
                },
                {
                    "schema": "http:\/\/pvm.forma-pro.com\/schemas\/TokenTransition.json",
                    "id": "e55033cc-4d9c-420a-bdcd-10cb4303c960",
                    "transitionId": "c0ae0bdf-3c49-4ce7-a140-9d6b33f2c90e",
                    "weight": 1,
                    "state": "passed",
                    "time": 16031629833241
                },
                {
                    "schema": "http:\/\/pvm.forma-pro.com\/schemas\/TokenTransition.json",
                    "id": "c3f894c4-8b76-4d46-bf2d-9ae10c59ac41",
                    "transitionId": "6d3ce293-a8aa-4f2b-9148-8d3d7fd5b2e9",
                    "weight": 1,
                    "state": "opened",
                    "time": 16031629833244
                },
                {
                    "schema": "http:\/\/pvm.forma-pro.com\/schemas\/TokenTransition.json",
                    "id": "26b11cc6-f17c-4402-9ac0-b566f9839b2b",
                    "transitionId": "6d3ce293-a8aa-4f2b-9148-8d3d7fd5b2e9",
                    "weight": 1,
                    "state": "passed",
                    "time": 16031629833247
                }
            ]
        },
        "7f38e493-c16e-4825-ac79-fda2c5187ada": {
            "schema": "http:\/\/pvm.forma-pro.com\/schemas\/Token.json",
            "id": "7f38e493-c16e-4825-ac79-fda2c5187ada",
            "transitions": [
                {
                    "schema": "http:\/\/pvm.forma-pro.com\/schemas\/TokenTransition.json",
                    "id": "b258efeb-4072-4d56-9c51-3331ffbbeabd",
                    "transitionId": "ecd164ca-9088-4ada-a9e8-0a7124a331c8",
                    "weight": 1,
                    "state": "opened",
                    "time": 16031629833251
                },
                {
                    "schema": "http:\/\/pvm.forma-pro.com\/schemas\/TokenTransition.json",
                    "id": "192cb2fc-fef2-4cc3-acd6-e467b934d0f7",
                    "transitionId": "ecd164ca-9088-4ada-a9e8-0a7124a331c8",
                    "weight": 1,
                    "state": "passed",
                    "time": 16031629833254
                }
            ]
        }
    }
}