test/hyperf
1
0
Fork 0
mirror of https://gitee.com/hyperf/hyperf.git synced 2024-12-04 04:37:46 +08:00
Code Issues Actions 16 Packages Projects Releases Wiki Activity

use non-blocking locks.

Browse Source
This commit is contained in:
Reasno 2020-04-21 14:05:42 +08:00
parent 6739970444
commit bbd1bcea20
20 changed files with 24 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/utils/src/Filesystem/Filesystem.php
View File

@ -56,13 +56,17 @@ class Filesystem
$contents = '';
$handle = fopen($path, 'rb');
if ($handle) {
$wouldBlock = false;
flock($handle, LOCK_SH | LOCK_NB, $wouldBlock);
while ($wouldBlock) {
usleep(1000);
flock($handle, LOCK_SH | LOCK_NB, $wouldBlock);
}
try {
if (flock($handle, LOCK_SH)) {
clearstatcache(true, $path);
$contents = fread($handle, $this->size($path) ?: 1);
flock($handle, LOCK_UN);
}
clearstatcache(true, $path);
$contents = fread($handle, $this->size($path) ?: 1);
} finally {
flock($handle, LOCK_UN);
fclose($handle);
}
}
@ -112,7 +116,21 @@ class Filesystem
{
if ($lock) {
return $this->atomic($path, function ($path) use ($contents, $lock) {
return file_put_contents($path, $contents, LOCK_EX);
$handle = fopen($path, 'w+');
if ($handle) {
$wouldBlock = false;
flock($handle, LOCK_EX | LOCK_NB, $wouldBlock);
while ($wouldBlock) {
usleep(1000);
flock($handle, LOCK_EX | LOCK_NB, $wouldBlock);
}
try {
fwrite($handle, $contents);
} finally {
flock($handle, LOCK_UN);
fclose($handle);
}
}
});
}
return file_put_contents($path, $contents);

1
src/utils/tests/ArrTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils;
use Hyperf\Utils\Arr;

1
src/utils/tests/BackoffTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils;
use Hyperf\Utils\Backoff;

1
src/utils/tests/CodeGen/ProjectTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\CodeGen;
use Hyperf\Utils\CodeGen\Project;

1
src/utils/tests/Codec/Base62Test.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\Codec;
use Hyperf\Utils\Codec\Base62;

1
src/utils/tests/Codec/JsonTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\Codec;
use Hyperf\Utils\Codec\Json;

1
src/utils/tests/CollectionTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils;
use Hyperf\Utils\Collection;

1
src/utils/tests/ContextTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils;
use Hyperf\Utils\Context;

1
src/utils/tests/Coordinator/CoordinatorTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\Coordinator;
use Hyperf\Utils\Coordinator\Coordinator;

1
src/utils/tests/Coroutine/ConcurrentTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\Coroutine;
use Hyperf\Utils\ApplicationContext;

1
src/utils/tests/Exception/RetryException.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\Exception;
class RetryException extends \Exception

1
src/utils/tests/FunctionTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils;
use HyperfTest\Utils\Exception\RetryException;

1
src/utils/tests/ParallelTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils;
use Hyperf\Utils\Coroutine;

1
src/utils/tests/Serializer/ExceptionNormalizerTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\Serializer;
use Hyperf\Utils\Serializer\ExceptionNormalizer;

1
src/utils/tests/Serializer/SymfonySerializerTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\Serializer;
use Hyperf\Utils\Serializer\SerializerFactory;

1
src/utils/tests/Stub/Foo.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\Stub;
class Foo

1
src/utils/tests/Stub/FooException.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\Stub;
class FooException extends \Exception

1
src/utils/tests/Stub/SerializableException.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\Stub;
class SerializableException extends \RuntimeException implements \Serializable

1
src/utils/tests/Traits/ContainerTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils\Traits;
use Hyperf\Utils\Traits\Container;

1
src/utils/tests/WaitGroupTest.php
View File

@ -9,7 +9,6 @@ declare(strict_types=1);
* @contact group@hyperf.io
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
*/
namespace HyperfTest\Utils;
use Hyperf\Utils\WaitGroup;