Помощь в блокировке процессов в php

* Необходимо написать класс реализующий блокировку процессов.
* Блокировки используются для проверки параллельного запуска процессов
* чтобы не запускать несколько одинаковых процессов тогда, когда это вредно.
*
* Например, скрипт импортирующий новости запускается по крону каждую минуту.
* Необходимо проверить, что предыдущий импорт уже завершился, иначе
* произойдёт дублирование новостей. Кроме крона могут быть и другие применения.
*
* Должно работать на windows и unix.
*
* Важно: необходимо предусмотреть ситуацию, когда скрипт импорта вылетит с FATAL
* не дойдя до крайней строки освобождения блокировки. В этом случае блокировка
* не должна висеть вечно.
*
* При выполнении этого задания, бОльшее значение имеет качество написанного вами кода.
* Не важно сколько времени вы потратите: 15 минут или 1.5 часа, ведь вы пишете
* универсальный класс который будет переиспользован многократно в разных проектах
* для разных задач на потяжении многих лет.
*
* Пожалуйста, реализуйте класс и пришлите файл Blocker.php

Нужна помощь в концепции, как сделать. Реализация не обязательна

 

Я вот думаю, реализовать через таблицу в БД, что бы получилось универсально для ОС. Выставлять к названиям файла скрипта флаги, типо: DONE, FAIL, START итд

 

lock($f, LOCK_EX + LOCK_NB) Что то типо такого? через создание файла?

 

PHP:

1. <?php
2.  
3. /**
4. * Блокератор
5. */
6. class Blocker
7. {
8.     const EXT_LOCK_FILE = '.pid';
9.  
10.     private $id;
11.     private $tmpDirectory;
12.  
13.     private $filePath;
14.     private $lock;
15.  
16.     private $fileManger;
17.  
18.     /**
19.      * @param string $id Идентификатор блокировки
20.      * @param FileManagerInterface $fileManager Файл Менеджер
21.      */
22.     public function __construct($id, FileManagerInterface $fileManager)
23.     {
24.         $this->id = $id;
25.         $this->tmpDirectory = sys_get_temp_dir();
26.         $this->filePath = $this->tmpDirectory . DIRECTORY_SEPARATOR . $this->id . self::EXT_LOCK_FILE;
27.         $this->fileManger = new FileManager();
28.     }
29.  
30.     public function isLock()
31.     {
32.         $this->lock = $this->isFileAndProcessActive();
33.         return $this->lock;
34.     }
35.  
36.     public function getLock()
37.     {
38.         return $this->lock;
39.     }
40.  
41.     /**
42.      * @return bool
43.      */
44.     public function setLock()
45.     {
46.         if ($this->isLock()) {
47.             return true;
48.         }
49.  
50.         try {
51.             $pid = getmypid();
52.  
53.             /**
54.              * @var File $file
55.              */
56.             $file = $this->fileManger->create($this->filePath, 'a');
57.  
58.             $file->truncate(0);
59.             $file->write($pid);
60.             $file->lock(LOCK_EX + LOCK_NB);
61.             $file->close();
62.  
63.         } catch (Exception $e) {
64.             echo 'Выброшено исключение: ', $e->getMessage(), "\n";
65.             exit(-1);
66.         }
67.     }
68.  
69.  
70.     /**
71.      * Пытается получить блокировку
72.      *
73.      * @return    boolean
74.      */
75.     public function open()
76.     {
77.         if ($this->isLock()) {
78.             return false;
79.         }
80.  
81.         $this->setLock();
82.         return true;
83.     }
84.  
85.     /**
86.      * Высвобождает блокировку
87.      *
88.      * @return    void
89.      */
90.     public function close()
91.     {
92.         /**
93.          * @var File $file
94.          */
95.         $file = $this->fileManger->create($this->filePath, 'r+');
96.         $file->flush();
97.         $file->lock(LOCK_UN);
98.         $file->close();
99.  
100.         $this->fileManger->delete($file);
101.     }
102.  
103.     private function isFileAndProcessActive()
104.     {
105.         /**
106.          * @var File $file
107.          */
108.         $file = $this->fileManger->create($this->filePath, 'r+');
109.         if ($file->isExist()) {
110.             $pid = intval($file->getContent());
111.  
112.             if (posix_kill($pid, 0)) {
113.                 return true;
114.             } else {
115.                 if (!$this->fileManger->delete($file)) {
116.                     exit(-1);
117.                 }
118.             }
119.         }
120.         return false;
121.     }
122.  
123.  
124. }

Набросал код,
Теперь проблема с posix_kill на WIndows, как на windows проверить процесс с индефикатором?
getmypid - работает как под linux как под windows