init

Author: levcoder

.gitignore

@@ -0,0 +1,3 @@
+/.idea
+/vendor
+composer.lock

MIT-LICENSE.md

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2021 Dima Levischenko
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,56 @@
+## Installation
+
+The preferred way to install this extension is through [composer](http://getcomposer.org/download/).
+
+Either run
+
+```bash
+php composer.phar require --prefer-dist hex-abyss/duplicate "*"
+```
+
+or add
+
+```json
+"hex-abyss/duplicate": "*"
+```
+
+to the require section of your `composer.json` file.
+
+## Usage
+
+```php
+while(true){
+    //some code
+    if (\hexAbyss\Duplicate::isStopProcess())
+        break;
+}
+```
+
+```php
+while(true){
+    //some code
+    \hexAbyss\Duplicate::isExit();
+}
+```
+
+```php
+//file: index.php
+while(true){
+    //some code
+    if (\hexAbyss\Duplicate::isStopProcess())
+        break;
+}
+
+//file: info.php
+\hexAbyss\Duplicate::getInstance('keyInfo');
+while(true){
+    //some code
+    if (\hexAbyss\Duplicate::isStopProcess())
+        break;
+}
+```
+
+## License
+
+The source code for the site is licensed under the MIT license, which you can find in
+the MIT-LICENSE.md file.

composer.json

@@ -0,0 +1,25 @@
+{
+    "name": "hex-abyss/duplicate",
+    "description": "To check is duplicate process",
+    "keywords": ["console", "process", "duplicate", "duplicate process", "stop process", "stop fork process", "stop other process"],
+    "license": "MIT",
+    "homepage": "https://github.com/hex-abyss/duplicate",
+    "authors": [
+        {
+            "name": "Dima Levischenko",
+            "email": "[email protected]"
+        }
+    ],
+    "support": {
+        "issues": "https://github.com/hex-abyss/duplicate/issues?state=open",
+        "source": "https://github.com/hex-abyss/duplicate"
+    },
+    "autoload": {
+        "psr-4": {
+            "hexAbyss\\": "src"
+        }
+    },
+    "require": {
+        "php": ">5.2"
+    }
+}

src/Duplicate.php

@@ -0,0 +1,85 @@
+<?php
+
+namespace hexAbyss;
+
+/**
+ * To check is duplicate process
+ *
+ * @package hexAbyss
+ */
+class Duplicate
+{
+    private static $pid;
+    private static $pidFile;
+    private static $instance;
+
+    /**
+     * Duplicate constructor.
+     * @param string $processPrefix
+     */
+    private function __construct($processPrefix = '')
+    {
+        self::$pid = getmypid();
+        self::$pidFile = sys_get_temp_dir() . DIRECTORY_SEPARATOR . $processPrefix . '_process.pid';
+
+        if ($this->createPidFile()) {
+            register_shutdown_function([$this, 'removePidFile']);
+        }
+    }
+
+    /**
+     * @param string $processPrefix
+     * @return self
+     */
+    public static function getInstance($processPrefix = '')
+    {
+        if (null === self::$instance) {
+            self::$instance = new self($processPrefix);
+        }
+
+        return self::$instance;
+    }
+
+    /**
+     * @param string $message
+     * @return void
+     */
+    public static function isExit($message = '')
+    {
+        if (self::isStopProcess()) {
+            exit($message);
+        }
+    }
+
+    /**
+     * @return bool
+     */
+    public static function isStopProcess()
+    {
+        if (null === self::$instance) {
+            self::getInstance();
+        }
+
+        if (file_exists(self::$pidFile)) {
+            return ((int)file_get_contents(self::$pidFile)) !== self::$pid;
+        }
+
+        return true;
+    }
+
+    /**
+     * @return bool
+     */
+    public static function removePidFile()
+    {
+        return file_exists(self::$pidFile) && !self::isStopProcess() && unlink(self::$pidFile);
+    }
+
+    /**
+     * @return false|int
+     */
+    private function createPidFile()
+    {
+        return file_put_contents(self::$pidFile, self::$pid, LOCK_EX);
+    }
+}