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 Article

Roblox: Bubble Gum Simulator Infinity - How To Get And Use Royal Keys
4 weeks ago By 尊渡假赌尊渡假赌尊渡假赌
Nordhold: Fusion System, Explained
1 months ago By 尊渡假赌尊渡假赌尊渡假赌
Mandragora: Whispers Of The Witch Tree - How To Unlock The Grappling Hook
4 weeks ago By 尊渡假赌尊渡假赌尊渡假赌

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)

Hot Topics

Java Tutorial
1677
14
PHP Tutorial
1279
29
C# Tutorial
1257
24
PHP and Python: Different Paradigms Explained PHP and Python: Different Paradigms Explained Apr 18, 2025 am 12:26 AM

PHP is mainly procedural programming, but also supports object-oriented programming (OOP); Python supports a variety of paradigms, including OOP, functional and procedural programming. PHP is suitable for web development, and Python is suitable for a variety of applications such as data analysis and machine learning.

PHP's Purpose: Building Dynamic Websites PHP's Purpose: Building Dynamic Websites Apr 15, 2025 am 12:18 AM

PHP is used to build dynamic websites, and its core functions include: 1. Generate dynamic content and generate web pages in real time by connecting with the database; 2. Process user interaction and form submissions, verify inputs and respond to operations; 3. Manage sessions and user authentication to provide a personalized experience; 4. Optimize performance and follow best practices to improve website efficiency and security.

Choosing Between PHP and Python: A Guide Choosing Between PHP and Python: A Guide Apr 18, 2025 am 12:24 AM

PHP is suitable for web development and rapid prototyping, and Python is suitable for data science and machine learning. 1.PHP is used for dynamic web development, with simple syntax and suitable for rapid development. 2. Python has concise syntax, is suitable for multiple fields, and has a strong library ecosystem.

PHP and Python: A Deep Dive into Their History PHP and Python: A Deep Dive into Their History Apr 18, 2025 am 12:25 AM

PHP originated in 1994 and was developed by RasmusLerdorf. It was originally used to track website visitors and gradually evolved into a server-side scripting language and was widely used in web development. Python was developed by Guidovan Rossum in the late 1980s and was first released in 1991. It emphasizes code readability and simplicity, and is suitable for scientific computing, data analysis and other fields.

Why Use PHP? Advantages and Benefits Explained Why Use PHP? Advantages and Benefits Explained Apr 16, 2025 am 12:16 AM

The core benefits of PHP include ease of learning, strong web development support, rich libraries and frameworks, high performance and scalability, cross-platform compatibility, and cost-effectiveness. 1) Easy to learn and use, suitable for beginners; 2) Good integration with web servers and supports multiple databases; 3) Have powerful frameworks such as Laravel; 4) High performance can be achieved through optimization; 5) Support multiple operating systems; 6) Open source to reduce development costs.

PHP's Impact: Web Development and Beyond PHP's Impact: Web Development and Beyond Apr 18, 2025 am 12:10 AM

PHPhassignificantlyimpactedwebdevelopmentandextendsbeyondit.1)ItpowersmajorplatformslikeWordPressandexcelsindatabaseinteractions.2)PHP'sadaptabilityallowsittoscaleforlargeapplicationsusingframeworkslikeLaravel.3)Beyondweb,PHPisusedincommand-linescrip

PHP vs. Python: Use Cases and Applications PHP vs. Python: Use Cases and Applications Apr 17, 2025 am 12:23 AM

PHP is suitable for web development and content management systems, and Python is suitable for data science, machine learning and automation scripts. 1.PHP performs well in building fast and scalable websites and applications and is commonly used in CMS such as WordPress. 2. Python has performed outstandingly in the fields of data science and machine learning, with rich libraries such as NumPy and TensorFlow.

The Continued Use of PHP: Reasons for Its Endurance The Continued Use of PHP: Reasons for Its Endurance Apr 19, 2025 am 12:23 AM

What’s still popular is the ease of use, flexibility and a strong ecosystem. 1) Ease of use and simple syntax make it the first choice for beginners. 2) Closely integrated with web development, excellent interaction with HTTP requests and database. 3) The huge ecosystem provides a wealth of tools and libraries. 4) Active community and open source nature adapts them to new needs and technology trends.

See all articles