src/Queue.php · ThinkYoung/php-queue

代码拉取完成,页面将自动刷新

扫描微信二维码支付

取消

支付完成

richgiteeai

Watch

不关注关注所有动态仅关注版本发行动态关注但不提醒动态

1 Star 0 Fork 11

ThinkYoung/php-queue

forked from inhere/php-queue

代码 Issues 0 Pull Requests 0 Wiki 统计流水线

服务

加入 Gitee

与超过 1400万开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)

免费加入

已有帐号? 立即登录

文件

master

分支 (1)

管理

master

克隆/下载

HTTPS SSH SVN SVN+SSH 下载ZIP

提示

下载代码请复制以下命令到终端执行

为确保你提交的代码身份被 Gitee 正确识别,请执行以下命令完成配置

git config --global user.name userName 
git config --global user.email userEmail

初次使用 SSH 协议进行代码克隆、推送等操作时,需按下述提示完成 SSH 配置

1 生成 RSA 密钥

2 获取 RSA 公钥内容,并配置到 SSH公钥中

在 Gitee 上使用 SVN,请访问使用指南

使用 HTTPS 协议时,命令行会出现如下账号密码验证步骤。基于安全考虑,Gitee 建议配置并使用私人令牌替代登录密码进行克隆、推送等操作

Username for 'https://gitee.com': userName

Password for 'https://userName@gitee.com': # 私人令牌

分支 1

标签 0

php-queue

src

Queue.php

Queue.php 1.63 KB

<?php
/**
 * Created by PhpStorm.
 * User: inhere
 * Date: 2017年5月29日
 * Time: 上午10:36
 */

namespace Inhere\Queue;

use Inhere\Queue\Driver\DbQueue;
use Inhere\Queue\Driver\PhpQueue;
use Inhere\Queue\Driver\RedisQueue;
use Inhere\Queue\Driver\ShmQueue;
use Inhere\Queue\Driver\SysVQueue;

/**
 * Class Queue - queue factory
 * @package Inhere\Queue
 */
final class Queue
{
 const DRIVER_DB = 'db';
 const DRIVER_PHP = 'php';
 // const DRIVER_LDB = 'levelDb';
 // const DRIVER_RDB = 'rocksDb';
 const DRIVER_SHM = 'shm';
 const DRIVER_SYSV = 'sysv';
 const DRIVER_REDIS = 'redis';

/**
 * driver map
 * @var array
 */
 private static $driverMap = [
 'db' => DbQueue::class,
 'php' => PhpQueue::class,
 'sysv' => SysVQueue::class,
 'shm' => ShmQueue::class,
 'redis' => RedisQueue::class,
 ];

/**
 * @param string $driver
 * @param array $config
 * @return QueueInterface
 */
 public static function make(array $config = [], $driver = '')
 {
 if (!$driver && isset($config['driver'])) {
 $driver = $config['driver'];
 unset($config['driver']);
 }

if ($driver && ($class = self::getDriverClass($driver))) {
 return new $class($config);
 }

return new PhpQueue($config);
 }

/**
 * @param $driver
 * @return mixed|null
 */
 public static function getDriverClass($driver)
 {
 return self::$driverMap[$driver] ?? null;
 }

/**
 * @return array
 */
 public static function getDriverMap(): array
 {
 return self::$driverMap;
 }
}

一键复制编辑原始数据按行查看历史

inhere 提交于 2018年03月07日 11:13 +08:00 . remove dep inhere/library. add other package dep

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

<?php
/**
 * Created by PhpStorm.
 * User: inhere
 * Date: 2017年5月29日
 * Time: 上午10:36
 */

namespace Inhere\Queue;

use Inhere\Queue\Driver\DbQueue;
use Inhere\Queue\Driver\PhpQueue;
use Inhere\Queue\Driver\RedisQueue;
use Inhere\Queue\Driver\ShmQueue;
use Inhere\Queue\Driver\SysVQueue;

/**
 * Class Queue - queue factory
 * @package Inhere\Queue
 */
final class Queue
{
 const DRIVER_DB = 'db';
 const DRIVER_PHP = 'php';
 // const DRIVER_LDB = 'levelDb';
 // const DRIVER_RDB = 'rocksDb';
 const DRIVER_SHM = 'shm';
 const DRIVER_SYSV = 'sysv';
 const DRIVER_REDIS = 'redis';

 /**
 * driver map
 * @var array
 */
 private static $driverMap = [
 'db' => DbQueue::class,
 'php' => PhpQueue::class,
 'sysv' => SysVQueue::class,
 'shm' => ShmQueue::class,
 'redis' => RedisQueue::class,
 ];

 /**
 * @param string $driver
 * @param array $config
 * @return QueueInterface
 */
 public static function make(array $config = [], $driver = '')
 {
 if (!$driver && isset($config['driver'])) {
 $driver = $config['driver'];
 unset($config['driver']);
 }

 if ($driver && ($class = self::getDriverClass($driver))) {
 return new $class($config);
 }

 return new PhpQueue($config);
 }

 /**
 * @param $driver
 * @return mixed|null
 */
 public static function getDriverClass($driver)
 {
 return self::$driverMap[$driver] ?? null;
 }

 /**
 * @return array
 */
 public static function getDriverMap(): array
 {
 return self::$driverMap;
 }
}