1: 2: 3: 4: 5: 6: 7: 8: 9: 10: 11: 12: 13: 14: 15: 16: 17: 18: 19: 20: 21: 22: 23: 24: 25: 26: 27: 28: 29: 30: 31: 32: 33: 34: 35: 36: 37: 38: 39: 40: 41: 42: 43: 44: 45: 46: 47: 48: 49: 50: 51: 52: 53: 54: 55: 56: 57: 58: 59: 60: 61: 62: 63: 64: 65: 66: 67: 68: 69: 70: 71: 72: 73: 74: 75: 76: 77: 78: 79: 80: 81: 82: 83: 84: 85: 86: 87: 88: 89: 90: 91: 92: 93: 94: 95: 96: 97: 98: 99: 100: 101: 102: 103: 104: 105: 106: 107: 108: 109: 110: 111: 112: 113: 114: 115: 116: 117: 118: 119: 120: 121: 122: 123: 124: 125: 126: 127: 128: 129: 130: 131: 132: 133: 134: 135: 136: 137: 138: 139: 140: 141: 142: 143: 144: 145: 146: 147: 148: 149: 150: 151: 152: 153: 154: 155: 156: 157: 158: 159: 160: 161: 162: 163: 164: 165: 166:
<?php
/**
* @author stev leibelt <artodeto@bazzline.net>
* @since 2014-07-20
*/
namespace Net\Bazzline\Component\ProcessForkManager;
/**
* Class AbstractTask
* @package Net\Bazzline\Component\ProcessForkManager
*/
abstract class AbstractTask implements TaskInterface
{
const STATUS_ABORTED = 2;
const STATUS_FINISHED = 1;
const STATUS_NOT_STARTED = 0;
const STATUS_RUNNING = 3;
/**
* @var int
*/
private $parentProcessId;
/**
* @var int
*/
private $startTime = 0;
/**
* @var int
*/
private $status = self::STATUS_NOT_STARTED;
/**
* @return int
*/
public function getRunTime()
{
return (time() - $this->startTime);
}
/**
* @return int
*/
public function getMemoryUsage()
{
return memory_get_usage(true);
}
/**
* @return int
*/
public function getParentProcessId()
{
return $this->parentProcessId;
}
/**
* @return int
*/
public function getProcessId()
{
return getmypid();
}
/**
* @return bool
*/
public function isAborted()
{
return ($this->status === self::STATUS_ABORTED);
}
/**
* @return bool
*/
public function isFinished()
{
return ($this->status === self::STATUS_FINISHED);
}
/**
* @return bool
*/
public function isNotStarted()
{
return ($this->status === self::STATUS_NOT_STARTED);
}
/**
* @return bool
*/
public function isRunning()
{
return ($this->status === self::STATUS_RUNNING);
}
public function markAsAborted()
{
$this->status = self::STATUS_ABORTED;
}
public function markAsFinished()
{
$this->status = self::STATUS_FINISHED;
}
public function markAsRunning()
{
$this->status = self::STATUS_RUNNING;
}
/**
* @param int $parentProcessId
*/
public function setParentProcessId($parentProcessId)
{
$this->parentProcessId = (int) $parentProcessId;
}
/**
* @param int $timestamp
*/
public function setStartTime($timestamp)
{
$this->startTime = (int) $timestamp;
}
protected function dispatchSignal()
{
pcntl_signal_dispatch();
}
/**
* @param $nameOfSignalHandlerMethod
* @throws InvalidArgumentException
* @codeCoverageIgnore
*/
protected function setUpSignalHandling($nameOfSignalHandlerMethod)
{
if (!is_callable(array($this, $nameOfSignalHandlerMethod))) {
throw new InvalidArgumentException(
'provided method name "' . $nameOfSignalHandlerMethod . '" is not available'
);
}
//pcntl_signal(SIGHUP, array($this, $nameOfSignalHandlerMethod));
pcntl_signal(SIGINT, array($this, $nameOfSignalHandlerMethod)); //shell ctrl+c
//pcntl_signal(SIGUSR1, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGUSR2, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGQUIT, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGILL, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGABRT, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGFPE, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGSEGV, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGPIPE, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGALRM, array($this, $nameOfSignalHandlerMethod));
pcntl_signal(SIGTERM, array($this, $nameOfSignalHandlerMethod)); //kill <pid>
//pcntl_signal(SIGCHLD, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGCONT, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGTSTP, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGTTIN, array($this, $nameOfSignalHandlerMethod));
//pcntl_signal(SIGTTOU, array($this, $nameOfSignalHandlerMethod));
}
}