<?php

namespace EasyTask;

/**
 * Class Queue
 * @package EasyTask
 */
class Queue
{
 /**
 * 进程锁
 * @var Lock
 */
 private $lock;

 /**
 * 队列文件
 * @var string
 */
 private $queFile;

 /**
 * 构造函数
 * @param string $name
 * @throws
 */
 public function __construct($name = 'queue')
 {
 // 创建进程锁
 $this->lock = new Lock($name);

 // 创建队列文件
 $path = Helper::getQuePath();
 $file = $path . '%s.dat';
 $this->queFile = sprintf($file, md5($name));
 if (!file_exists($this->queFile)) {
 if (!file_put_contents($this->queFile, '[]', LOCK_EX)) {
 Helper::showError('crate queFile failed,please try again');
 }
 }
 }

 /**
 * 向队列投递数据
 * @param string $item
 */
 public function push($item)
 {
 $this->lock->execute(
 function () use ($item) {
 // read
 $content = file_get_contents($this->queFile);
 $queue_data = $content ? json_decode($content, true) : [];
 $queue_data = is_array($queue_data) ? $queue_data : [];

 // write
 array_push($queue_data, $item);
 if (!file_put_contents($this->queFile, json_encode($queue_data))) {
 Helper::showError('failed to save data to queue file');
 }
 }
 );
 }

 /**
 * 从队列弹出数据
 * @return string|null
 */
 public function shift()
 {
 return $this->lock->execute(
 function () {
 // read
 $content = file_get_contents($this->queFile);
 $queue_data = $content ? json_decode($content, true) : [];
 $queue_data = is_array($queue_data) ? $queue_data : [];

 // shift+write
 $value = array_shift($queue_data);
 if (!file_put_contents($this->queFile, json_encode($queue_data))) {
 Helper::showError('failed to save data to queue file');
 }
 return $value;
 }
 );
 }
}