YGGverse/Yoda
1
0
Fork 0
mirror of https://github.com/YGGverse/Yoda.git synced 2026-04-02 09:35:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

implement shared memory pool model

Browse source
This commit is contained in:
yggverse 2024-07-17 09:53:33 +03:00
parent 1d2641dceb
commit 8b28265204
2 changed files with 86 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

16
src/Interface/Model/Pool.php
View file

@ -10,12 +10,22 @@ namespace Yggverse\Yoda\Interface\Model;
*/ */
interface Pool interface Pool
{ {
public function __construct(
?string $namespace = null
);
public function get( public function get(
string $key string $key
): mixed; ): ?string;
public function set( public function set(
string $key, string $key,
mixed $value string $value,
): void; string $flags = 'c',
int $offset = 0,
int $mode = 0644,
?string $encoding = null
): int;
public function reset(): void;
} }

73
src/Model/Pool.php Normal file
View file

@ -0,0 +1,73 @@
<?php
declare(strict_types=1);
namespace Yggverse\Yoda\Model;
class Pool implements \Yggverse\Yoda\Interface\Model\Pool
{
private string $_namespace;
private array $_data = [];
public function __construct(
?string $namespace = null
) {
$this->_namespace = __FILE__ . (
$namespace ? $namespace : uniqid()
);
}
public function get(
string $key,
int $start = 0,
int $count = 0
): ?string
{
if (isset($this->_data[$key]))
{
return shmop_read(
$this->_data[$key],
$start,
$count ? $count : shmop_size(
$this->_data[$key]
)
);
}
return null;
}
public function set(
string $key,
string $value,
string $flags = 'c',
int $offset = 0,
int $mode = 0644,
?string $encoding = null
): int
{
if ($this->_data[$key] = shmop_open(crc32($this->_namespace . $key), $flags, $mode, mb_strlen($value, $encoding)))
{
return shmop_write(
$this->_data[$key],
$value,
$offset
);
}
throw new \Exception;
}
public function reset(): void
{
foreach ($this->_data as $data)
{
shmop_delete(
$data
);
}
$this->_data = [];
}
}