SlowPlusJob.php

Go to the documentation of this file.

<?php
 
namespace ILIAS\BackgroundTasks\Implementation\Tasks;
 
use ILIAS\BackgroundTasks\Implementation\Bucket\BucketMock;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\IntegerValue;
use ILIAS\BackgroundTasks\Observer;
use ILIAS\BackgroundTasks\Types\SingleType;
use ILIAS\BackgroundTasks\Types\Type;
use ILIAS\BackgroundTasks\Value;
 
class SlowPlusJob extends AbstractJob
{
    const SLEEP_SECONDS = 10;
 
 
    public function __construct()
    {
    }
 
 
    public function getInputTypes()
    {
        return [
            new SingleType(IntegerValue::class),
            new SingleType(IntegerValue::class),
        ];
    }
 
 
    public function getOutputType()
    {
        return new SingleType(IntegerValue::class);
    }
 
 
    public function run(array $input, Observer $observer)
    {
        $a = $input[0];
        $b = $input[1];
 
        sleep(self::SLEEP_SECONDS);
        $observer->notifyPercentage($this, 20);
        sleep(self::SLEEP_SECONDS);
        $observer->notifyPercentage($this, 40);
        sleep(self::SLEEP_SECONDS);
        $observer->notifyPercentage($this, 60);
        sleep(self::SLEEP_SECONDS);
        $observer->notifyPercentage($this, 80);
 
        $output = new IntegerValue();
        $output->setValue($a->getValue() + $b->getValue());
 
        return $output;
    }
 
 
    public function isStateless()
    {
        return true;
    }
 
 
    public function getExpectedTimeOfTaskInSeconds()
    {
        return 2;
    }
}