Home Backend Development PHP Tutorial Detailed explanation of file locks, mutex locks, and read-write locks in PHP

Detailed explanation of file locks, mutex locks, and read-write locks in PHP

Dec 29, 2017 pm 06:02 PM
php Detailed explanation Read and write

This article mainly introduces the analysis of file locks, mutex locks, and read-write locks in PHP programs. It focuses on the usage examples in the sync module and pthreads module. Friends in need can refer to it. I hope to be helpful.

File lock
The full name is advisory file lock, which is mentioned in the book. This type of lock is relatively common. For example, after mysql and php-fpm are started, there will be a pid file recording the process ID. This file is the file lock.

This lock can prevent a process from running repeatedly. For example, when using crontab, one task is limited to be executed every minute, but this process may run for more than one minute. If the process lock is not used to resolve the conflict, the two processes will be together. There will be problems with execution.

Another advantage of using PID file lock is that it is convenient for the process to send stop or restart signals to itself. For example, the command to restart php-fpm is

kill -USR2 `cat /usr/local/php/var/run/php-fpm.pid`
Send the USR2 signal to the process recorded in the pid file. The signal It belongs to process communication and will be opened in another chapter.

The interface of php is flock, and the documentation is relatively detailed. Let’s take a look at the definition first, bool flock ( resource $handle , int $operation [, int &$wouldblock ] ).

  • $handle is the file system pointer, which is typically used by fopen() The resource created. This means that a file must be opened to use flock.

  • $operation is the operation type.

  • &$wouldblock If the lock is blocking, then this variable will be set to 1.

It should be noted that this function defaults to Blocking. If you want to be non-blocking, you can add a bitmask LOCK_NB to the operation. Next, test it.


1

2

3

4

5

6

7

8

9

10

11

12

13

14

$pid_file = "/tmp/process.pid";

$pid = posix_getpid();

$fp = fopen($pid_file, 'w+');

if(flock($fp, LOCK_EX | LOCK_NB)){

  echo "got the lock \n";

  ftruncate($fp, 0);   // truncate file

  fwrite($fp, $pid);

  fflush($fp);      // flush output before releasing the lock

  sleep(300); // long running process

  flock($fp, LOCK_UN);  // 释放锁定

} else {

  echo "Cannot get pid lock. The process is already up \n";

}

fclose($fp);

Copy after login

Save it as process.php, run php process.php &, then run php process.php again and you will see the error message. flock also has shared locks, LOCK_SH.

Mutex locks and read-write locks
Mutex in the sync module:
Mutex is a compound word, mutual exclusion. Use pecl to install the sync module, pecl install sync. The SyncMutex in the document only has two methods, lock and unlock. Let’s go directly to the code test. I didn't write it in IDE, so the cs is extremely ugly, please ignore it.


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

$mutex = new SyncMutex("UniqueName");

 

for($i=0; $i<2; $i++){

  $pid = pcntl_fork();

  if($pid <0){

    die("fork failed");

  }elseif ($pid>0){

    echo "parent process \n";

  }else{

    echo "child process {$i} is born. \n";

    obtainLock($mutex, $i);

  }

}

 

while (pcntl_waitpid(0, $status) != -1) {

  $status = pcntl_wexitstatus($status);

  echo "Child $status completed\n";

}

 

function obtainLock ($mutex, $i){

  echo "process {$i} is getting the mutex \n";

  $res = $mutex->lock(200);

  sleep(1);

  if (!$res){

    echo "process {$i} unable to lock mutex. \n";

  }else{

    echo "process {$i} successfully got the mutex \n";

    $mutex->unlock();

  }

  exit();

}

Copy after login

Save as mutex.php, run php mutex.php, output is


##

1

2

3

4

5

6

7

8

9

10

parent process

parent process

child process 1 is born.

process 1 is getting the mutex

child process 0 is born.

process 0 is getting the mutex

process 1 successfully got the mutex

Child 0 completed

process 0 unable to lock mutex.

Child 0 completed

Copy after login
Copy after login

Here child process 0 And 1 does not necessarily mean who is in front. But there is always one who cannot get the lock. The parameter of SyncMutex::lock(int $millisecond) here is millisecond, which represents the blocking duration, and -1 means infinite blocking.

Read-write lock in the sync module:
The method of SyncReaderWriter is similar, readlock, readunlock, writelock, writeunlock, they can appear in pairs, no test code is written, it should be the same as Mutex The code is the same, just replace the lock.

Event in the sync module:
It feels more like Cond in golang, wait() blocks, and fire() wakes up a process blocked by Event. There is a good article introducing Cond. It can be seen that Cond is a fixed usage of locks. The same goes for SyncEvent.
The examples in the php documentation show that the fire() method seems to be used in web applications.

Test code

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

for($i=0; $i<3; $i++){

  $pid = pcntl_fork();

  if($pid <0){

    die("fork failed");

  }elseif ($pid>0){

    //echo "parent process \n";

  }else{

    echo "child process {$i} is born. \n";

    switch ($i) {

    case 0:

      wait();

      break;

    case 1:

      wait();

      break;

    case 2:

      sleep(1);

      fire();

      break;

    }

  }

}

 

while (pcntl_waitpid(0, $status) != -1) {

  $status = pcntl_wexitstatus($status);

  echo "Child $status completed\n";

}

 

function wait(){

  $event = new SyncEvent("UniqueName");

  echo "before waiting. \n";

  $event->wait();

  echo "after waiting. \n";

  exit();

}

 

function fire(){

  $event = new SyncEvent("UniqueName");

  $event->fire();

  exit();

}

Copy after login

There is one less fire() deliberately written here, so the program will block, which proves that fire() only wakes up one process at a time.

pthreads module
Lock and unlock mutex:

Function:

##

1

2

3

pthread_mutex_lock (mutex)

pthread_mutex_trylock (mutex)

pthread_mutex_unlock (mutex)

Copy after login

Usage:

The thread uses the pthread_mutex_lock() function to lock the specified mutex variable. If the mutex is already locked by another thread, this call will block the thread until the mutex is unlocked.

pthread_mutex_trylock() will attempt to lock a mutex. However, if the mutex is already locked, the routine will return immediately with a "busy" error code. This routine may be useful in pthread_mutex_trylock().


Attempt to lock a mutex. However, if the mutex is already locked, the program will return immediately and return a busy error value. This function is useful to prevent deadlock in the case of priority changes. A thread can use pthread_mutex_unlock() to unlock the mutex it occupies. This function can be called when one thread completes the use of protected data and other threads want to obtain a mutex to work on the protected data. If the following situation occurs, an error will occur:

    The mutex has been unlocked
  • The mutex is occupied by another thread
  • There is nothing "magical" about mutexes. In fact, they are the "gentleman's agreement" of the participating threads. When writing code, be sure to lock and unlock mutexes correctly.

Q: There are multiple threads waiting for the same locked mutex. When the mutex is unlocked, which thread will be the first to lock the mutex?

A: Unless the thread uses the priority scheduling mechanism, the thread will be allocated by the system scheduler, and which thread will be the first to lock the mutex is random.



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

#include<stdlib.h>

#include<stdio.h>

#include<unistd.h>

#include<pthread.h>

 

typedef struct ct_sum

{

  int sum;

  pthread_mutex_t lock;

}ct_sum;

 

void * add1(void *cnt)

{   

  pthread_mutex_lock(&(((ct_sum*)cnt)->lock));

  for(int i=0; i < 50; i++)

  {

    (*(ct_sum*)cnt).sum += i;  

  }

  pthread_mutex_unlock(&(((ct_sum*)cnt)->lock));

  pthread_exit(NULL);

  return 0;

}

void * add2(void *cnt)

{   

  pthread_mutex_lock(&(((ct_sum*)cnt)->lock));

  for(int i=50; i<101; i++)

  

     (*(ct_sum*)cnt).sum += i; 

  }

  pthread_mutex_unlock(&(((ct_sum*)cnt)->lock));

  pthread_exit(NULL);

  return 0;

}

  

int main(void)

{

  pthread_t ptid1, ptid2;

  ct_sum cnt;

  pthread_mutex_init(&(cnt.lock), NULL);

  cnt.sum=0;

  

  pthread_create(&ptid1, NULL, add1, &cnt);

  pthread_create(&ptid2, NULL, add2, &cnt);

   

  pthread_join(ptid1,NULL);

  pthread_join(ptid2,NULL);

 

  printf("sum %d\n", cnt.sum);

  pthread_mutex_destroy(&(cnt.lock));

 

  return 0;

}

Copy after login

信号量
sync模块中的信号量:
SyncSemaphore文档中显示,它和Mutex的不同之处,在于Semaphore一次可以被多个进程(或线程)得到,而Mutex一次只能被一个得到。所以在SyncSemaphore的构造函数中,有一个参数指定信号量可以被多少进程得到。
public SyncSemaphore::__construct ([ string $name [, integer $initialval [, bool $autounlock ]]] ) 就是这个$initialval (initial value)


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

$lock = new SyncSemaphore("UniqueName", 2);

 

for($i=0; $i<2; $i++){

  $pid = pcntl_fork();

  if($pid <0){

    die("fork failed");

  }elseif ($pid>0){

    echo "parent process \n";

  }else{

    echo "child process {$i} is born. \n";

    obtainLock($lock, $i);

  }

}

 

while (pcntl_waitpid(0, $status) != -1) {

  $status = pcntl_wexitstatus($status);

  echo "Child $status completed\n";

}

 

function obtainLock ($lock, $i){

  echo "process {$i} is getting the lock \n";

  $res = $lock->lock(200);

  sleep(1);

  if (!$res){

    echo "process {$i} unable to lock lock. \n";

  }else{

    echo "process {$i} successfully got the lock \n";

    $lock->unlock();

  }

  exit();

}

Copy after login

这时候两个进程都能得到锁。

  • sysvsem模块中的信号量

  • sem_get 创建信号量

  • sem_remove 删除信号量(一般不用)

  • sem_acquire 请求得到信号量

  • sem_release 释放信号量。和 sem_acquire 成对使用。


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

$key = ftok(&#39;/tmp&#39;, &#39;c&#39;);

 

$sem = sem_get($key);

 

for($i=0; $i<2; $i++){

  $pid = pcntl_fork();

  if($pid <0){

    die("fork failed");

  }elseif ($pid>0){

    //echo "parent process \n";

  }else{

    echo "child process {$i} is born. \n";

    obtainLock($sem, $i);

  }

}

 

while (pcntl_waitpid(0, $status) != -1) {

  $status = pcntl_wexitstatus($status);

  echo "Child $status completed\n";

}

sem_remove($sem); // finally remove the sem

 

function obtainLock ($sem, $i){

  echo "process {$i} is getting the sem \n";

  $res = sem_acquire($sem, true);

  sleep(1);

  if (!$res){

    echo "process {$i} unable to get sem. \n";

  }else{

    echo "process {$i} successfully got the sem \n";

    sem_release($sem);

  }

  exit();

}

Copy after login

这里有一个问题,sem_acquire()第二个参数$nowait默认为false,阻塞。我设为了true,如果得到锁失败,那么后面的sem_release会报警告 PHP Warning: sem_release(): SysV semaphore 4 (key 0x63000081) is not currently acquired in /home/jason/sysvsem.php on line 33, 所以这里的release操作必须放在得到锁的情况下执行,前面的几个例子中没有这个问题,没得到锁执行release也不会报错。当然最好还是成对出现,确保得到锁的情况下再release。
此外,ftok这个方法的参数有必要说明下,第一个 必须是existing, accessable的文件, 一般使用项目中的文件,第二个是单字符字符串。返回一个int。

输出为


1

2

3

4

5

6

7

8

9

10

parent process

parent process

child process 1 is born.

process 1 is getting the mutex

child process 0 is born.

process 0 is getting the mutex

process 1 successfully got the mutex

Child 0 completed

process 0 unable to lock mutex.

Child 0 completed

Copy after login
Copy after login

相关推荐:

简单介绍PHP 文件锁与进程锁

php 文件读取系列方法详解

简单谈谈 php 文件锁

The above is the detailed content of Detailed explanation of file locks, mutex locks, and read-write locks in PHP. For more information, please follow other related articles on the PHP Chinese website!

Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn

Hot AI Tools

Undresser.AI Undress

Undresser.AI Undress

AI-powered app for creating realistic nude photos

AI Clothes Remover

AI Clothes Remover

Online AI tool for removing clothes from photos.

Undress AI Tool

Undress AI Tool

Undress images for free

Clothoff.io

Clothoff.io

AI clothes remover

Video Face Swap

Video Face Swap

Swap faces in any video effortlessly with our completely free AI face swap tool!

Hot Tools

Notepad++7.3.1

Notepad++7.3.1

Easy-to-use and free code editor

SublimeText3 Chinese version

SublimeText3 Chinese version

Chinese version, very easy to use

Zend Studio 13.0.1

Zend Studio 13.0.1

Powerful PHP integrated development environment

Dreamweaver CS6

Dreamweaver CS6

Visual web development tools

SublimeText3 Mac version

SublimeText3 Mac version

God-level code editing software (SublimeText3)

PHP 8.4 Installation and Upgrade guide for Ubuntu and Debian PHP 8.4 Installation and Upgrade guide for Ubuntu and Debian Dec 24, 2024 pm 04:42 PM

PHP 8.4 brings several new features, security improvements, and performance improvements with healthy amounts of feature deprecations and removals. This guide explains how to install PHP 8.4 or upgrade to PHP 8.4 on Ubuntu, Debian, or their derivati

How To Set Up Visual Studio Code (VS Code) for PHP Development How To Set Up Visual Studio Code (VS Code) for PHP Development Dec 20, 2024 am 11:31 AM

Visual Studio Code, also known as VS Code, is a free source code editor — or integrated development environment (IDE) — available for all major operating systems. With a large collection of extensions for many programming languages, VS Code can be c

Explain JSON Web Tokens (JWT) and their use case in PHP APIs. Explain JSON Web Tokens (JWT) and their use case in PHP APIs. Apr 05, 2025 am 12:04 AM

JWT is an open standard based on JSON, used to securely transmit information between parties, mainly for identity authentication and information exchange. 1. JWT consists of three parts: Header, Payload and Signature. 2. The working principle of JWT includes three steps: generating JWT, verifying JWT and parsing Payload. 3. When using JWT for authentication in PHP, JWT can be generated and verified, and user role and permission information can be included in advanced usage. 4. Common errors include signature verification failure, token expiration, and payload oversized. Debugging skills include using debugging tools and logging. 5. Performance optimization and best practices include using appropriate signature algorithms, setting validity periods reasonably,

PHP Program to Count Vowels in a String PHP Program to Count Vowels in a String Feb 07, 2025 pm 12:12 PM

A string is a sequence of characters, including letters, numbers, and symbols. This tutorial will learn how to calculate the number of vowels in a given string in PHP using different methods. The vowels in English are a, e, i, o, u, and they can be uppercase or lowercase. What is a vowel? Vowels are alphabetic characters that represent a specific pronunciation. There are five vowels in English, including uppercase and lowercase: a, e, i, o, u Example 1 Input: String = "Tutorialspoint" Output: 6 explain The vowels in the string "Tutorialspoint" are u, o, i, a, o, i. There are 6 yuan in total

Explain late static binding in PHP (static::). Explain late static binding in PHP (static::). Apr 03, 2025 am 12:04 AM

Static binding (static::) implements late static binding (LSB) in PHP, allowing calling classes to be referenced in static contexts rather than defining classes. 1) The parsing process is performed at runtime, 2) Look up the call class in the inheritance relationship, 3) It may bring performance overhead.

How do you parse and process HTML/XML in PHP? How do you parse and process HTML/XML in PHP? Feb 07, 2025 am 11:57 AM

This tutorial demonstrates how to efficiently process XML documents using PHP. XML (eXtensible Markup Language) is a versatile text-based markup language designed for both human readability and machine parsing. It's commonly used for data storage an

What are PHP magic methods (__construct, __destruct, __call, __get, __set, etc.) and provide use cases? What are PHP magic methods (__construct, __destruct, __call, __get, __set, etc.) and provide use cases? Apr 03, 2025 am 12:03 AM

What are the magic methods of PHP? PHP's magic methods include: 1.\_\_construct, used to initialize objects; 2.\_\_destruct, used to clean up resources; 3.\_\_call, handle non-existent method calls; 4.\_\_get, implement dynamic attribute access; 5.\_\_set, implement dynamic attribute settings. These methods are automatically called in certain situations, improving code flexibility and efficiency.

PHP and Python: Comparing Two Popular Programming Languages PHP and Python: Comparing Two Popular Programming Languages Apr 14, 2025 am 12:13 AM

PHP and Python each have their own advantages, and choose according to project requirements. 1.PHP is suitable for web development, especially for rapid development and maintenance of websites. 2. Python is suitable for data science, machine learning and artificial intelligence, with concise syntax and suitable for beginners.

See all articles