PHP Classes


Recommend this page to a friend!
  Classes of Daniel Martinez  >  Forker PHP  >  >  Download  
Role: Auxiliary data
Content type: text/plain
Description: Auxiliary data
Class: Forker PHP
Split tasks into multiple forked processes
Author: By
Last change: Beginning splitting responsabilities
Date: 1 year ago
Size: 3,849 bytes


Class file image Download
[![Build Status](](
[![Latest Stable Version](](

## Synopsis

A structured , safe, and easiest way to perform tasks parallely in PHP.

## Code Example

 * Example: Retrieving the city-weather using external api
 * Usage  : php examples/ 
 * Storage: File
require 'vendor/autoload.php';

use Forker\Forker;
use Forker\Storage\FileStorage;

$allCitiesWeather = "";

$urlApiWeather = "";

$myTasks = array(
  'madrid'    => sprintf($urlApiWeather, 'Madrid'),
  'london'    => sprintf($urlApiWeather, 'London'),
  'new-york'  => sprintf($urlApiWeather, 'NewYork'),
  'barcelona' => sprintf($urlApiWeather, 'barcelona'),
  'lisboa'    => sprintf($urlApiWeather, 'lisboa'),
  'iasi'      => sprintf($urlApiWeather, 'iasi'),

// a way to keep our data
$storageSystem = new FileStorage;
$numberOfSubTasks = 6;

$forker = new Forker($storageSystem, $myTasks, $numberOfSubTasks);

$forker->fork(function($city, $url,  $emit) {
  echo "Retrieving weather in $city\n";
  $contents = file_get_contents($url);
  $emit($city, $contents);

$allCitiesWeather = $forker->fetch();

## Motivation

Sometimes we have to work with a huge amount of data. 
[Lately](, more and more, and it's just no possible to work sequentially these times. 

For example, we have two cooks in a kitchen and a very big carrot.
Well, we want our two workers not to be waiting for each other. 
So why we don't split the carrot in two parts so they can work each one with a part ?

This way both cooks can work together, at the same time, and we will have our dinner soon ! Great huh ?

So, the intention is to make an agile and encapsulated way to split a task in several child subtasks in parallel.

## Install

Using composer:
  "require": {
        "danibrutal/forker": "dev-master"

## API Reference

You can check the API out [here](;
## Creating your own StorageSystem:
We follow here a TDD aproach so is extremely easy to develop a new system:

1º Create your own storage system following the StorageSystem interface's signature:
   * @param key
   * @param value
   * @return bool
  public function store($key, $value);

   * @param key
   * @return value | false
  public function get($key);

   * @return array $tasks
  public function getStoredTasks();

   * @return bool
  public function cleanUp();
2º Creates a test
use Forker\Storage\ArrayStorage;
require_once 'BaseStorageTest.php';

class ArrayStorageTest extends BaseStorageTest
    protected function getSystemStorage()
        return new ArrayStorage();        
Hard, huh?

3º Then, type phpunit so you can see 3 errors to solve:
There were 4 failures:

1) ArrayStorageTest::testWeCanGetASimpleStoredValue
Failed asserting that null matches expected 'value'.

2) ArrayStorageTest::testWeCanSToreValues
Failed asserting that null is true.

3) ArrayStorageTest::testIcanGetAllMyStoredTasks
Failed asserting that a NULL is not empty.

4) ArrayStorageTest::testWeCanCleanUpAllPreviousTasks
Failed asserting that a NULL is not empty.

4º Just solve the errors. Create your implementation and you are done!
Easy and funny :)

## Contributors
Please, feel free to colaborate. Fork the project and check [issues][2].
We still have so much work ahead!.

## License