Как пользоваться flock()?

Если вы решаете задачу конкурентного доступа к файлу (или какому то другому ресурсу) в PHP, и решили использовать flock() для этой цели, то вам понадобится верно представлять как работает механизм блокировки.

Представим себе, что есть разные программные потоки, одни из которых читают данные — «читатели», а другие их меняют — «писари». Ясно, что «читатель» должен дождаться пока операции записи завершатся. При этом несколько «читателей» не мешают друг другу.

Семафор

Чтобы блокировка работала, необходимо использовать один и тот же способ блокировки. Иными словами, flock() нужно вызывать как при чтении, так и при записи.

В случае с «семафорным» файлом код может выглядеть вот так:

//поток читателя
$semHandler = fopen($filename, 'r');
if (flock($semHandler, LOCK_SH)) {
   //выполняем операции чтения
}
flock($semHandler, LOCK_UN);
fclose($semHandler);

//поток писаря
$semHandler = fopen($filename, 'r');
if (flock($semHandler, LOCK_EX)) {
   //выполняем операции записи
}
flock($semHandler, LOCK_UN);
fclose($semHandler);

//поток читателя

$semHandler = fopen($filename, 'r');

if (flock($semHandler, LOCK_SH)) {

//выполняем операции чтения

}

flock($semHandler, LOCK_UN);

fclose($semHandler);

//поток писаря

$semHandler = fopen($filename, 'r');

if (flock($semHandler, LOCK_EX)) {

//выполняем операции записи

}

flock($semHandler, LOCK_UN);

fclose($semHandler);

Т.е. мы проводим блокировку некого файла-семафора, а запись и чтение проводится с другими объектами.

Блокировка

Если нужно провести блокировку объекта, с которым проводятся непосредственные операции чтения-записи, то открывать файл «писарем» потребуется в специальном режиме. Режимы ‘w’ и ‘w+’ тут не подходят, т.к. до получения блокировки, содержимое файла менять нельзя.

//поток писаря
$fh = fopen($filename, 'c');
if (flock($fh, LOCK_EX)) {
   //блокировка получена, теперь можно менять файл
   //удалили данные
   ftruncate($fh, 0); 
   //перезаписали
   fwrite($fh, $data);
}
//сняли блокировку
flock($fh, LOCK_UN);
fclose($fh);

//поток писаря

$fh = fopen($filename, 'c');

if (flock($fh, LOCK_EX)) {

//блокировка получена, теперь можно менять файл

//удалили данные

ftruncate($fh, 0);

//перезаписали

fwrite($fh, $data);

}

//сняли блокировку

flock($fh, LOCK_UN);

fclose($fh);

Для полноты примера, приведу код потока-читателя:

//поток читателя
$fh = fopen($filename, 'r');
if (flock($fh, LOCK_SH)) {
   //блокировка получена, теперь можно читать данные
   $data = @fread($fh, filesize($filename)); 
}
//сняли блокировку
flock($fh, LOCK_UN);
fclose($fh);

//поток читателя

$fh = fopen($filename, 'r');

if (flock($fh, LOCK_SH)) {

//блокировка получена, теперь можно читать данные

$data = @fread($fh, filesize($filename));

}

//сняли блокировку

flock($fh, LOCK_UN);

fclose($fh);

Блокировка с тайм-аутом

По умолчанию flock() ждет получения блокировки. Сколько продлится ожидание не известно, но можно использовать флаг LOCK_NB, чтобы не ждать, а самим решать, что делать дальше.

В данном примере ожидание продлится не более 50 мсек.

//поток читателя
$fh = fopen($filename, 'r');
$timeout_secs = 50; 
$got_lock = true;

while (!flock($fh, LOCK_SH | LOCK_NB, $wouldblock)) {
   if ($wouldblock && --$timeout_secs > 0) {
      sleep(1);
   } else {
      $got_lock = false;
      break;
   }
} 
if ($got_lock) {
   //дождались блокировки, читаем данные
   $data = @fread($fh, filesize($filename)); 
   flock($fh, LOCK_UN);
} else {
   //доступ не удалось получить за отведенное время 
   ...  
}
fclose($fh);

//поток читателя

$fh = fopen($filename, 'r');

$timeout_secs = 50;

$got_lock = true;

while (!flock($fh, LOCK_SH | LOCK_NB, $wouldblock)) {

if ($wouldblock && --$timeout_secs > 0) {

sleep(1);

} else {

$got_lock = false;

break;

}

if ($got_lock) {

//дождались блокировки, читаем данные

$data = @fread($fh, filesize($filename));

flock($fh, LOCK_UN);

} else {

//доступ не удалось получить за отведенное время

...

}

fclose($fh);

Если еще остались вопросы — пишите в комментариях. :)

Написать комментарий

Данная запись опубликована в 24.03.2017 06:28 и размещена в рубрике PHP. Вы можете перейти в конец страницы и оставить ваш комментарий.

Мало букафф? Читайте есчо !

Переводим массив в XML на PHP

Июнь 18, 2018 г.

Итак, как перевести ассоциативный массив в XML? Воспользуемся "родным" для PHP классом SimpleXMLElement. В качестве основного контейнера используем тег <values/>, а установить UTF-8 кодировку нам поможет небольшая хитрость. Инициализация ...

Читать

Поиск и замена терминов. Пример реализации.

Август 15, 2016 г.

Задача поиска и замены каких либо терминов в тексте кажется на первый взгляд довольно простой в PHP. Есть очень мощные инструменты вроде str_replace, а также поиск и замена с помощью регулярных выражений, например, preg_replace и preg_replace_callback. ...

Читать

Получение превью (картинки) для видео vimeo

Август 23, 2019 г.

Рассмотрим как получить thumbnail для видео vimeo, если у вас есть только url видоса. Vimeo позволяет извлечь мета информацию о видео, используя video id. Потому мы сначала выделим id, а потом выполним запрос к API Vimeo за дополнительной информацией, ...

Читать

Если simplexml "не парсит" атрибуты...

Август 12, 2017 г.

.. то скорее всего, вы ошибаетесь. Рассмотрим следующий пример XML. В документе example.xml содержится запись о валюте и информация о категории товара. Обе записи содержат аттрибуты. [crayon-6ae3726606b55378169976/] Выполним чтение и вывод информации ...

Читать

Комментарии к «Как пользоваться flock()?»

Понравилась статья? Есть вопросы? - пишите в комментариях.

Имя (обязательно)	Е-майл (не будет опубликован на сайте, обязательно для заполнения)
Комментарий: