as2252258/kiri-container
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

eee

Browse Source
This commit is contained in:
xl
2024-11-06 21:47:21 +08:00
parent 03bffb5e5b
commit 9775d16db5
1 changed files with 33 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Context/CoroutineContext.php
+33 -11
View File
@@ -26,7 +26,11 @@ class CoroutineContext implements ContextInterface
*/ */
public static function set(string $key, mixed $value, ?int $coroutineId = null): mixed public static function set(string $key, mixed $value, ?int $coroutineId = null): mixed
{ {
return Coroutine::getContext()[$key] = $value; // TODO: Implement set() method.
if (is_null($coroutineId)) {
$coroutineId = Coroutine::getCid();
}
return Coroutine::getContext($coroutineId)[$key] = $value;
} }
/** /**
@@ -37,7 +41,11 @@ class CoroutineContext implements ContextInterface
*/ */
public static function get(string $key, mixed $defaultValue = null, ?int $coroutineId = null): mixed public static function get(string $key, mixed $defaultValue = null, ?int $coroutineId = null): mixed
{ {
return Coroutine::getContext()[$key] ?? $defaultValue; // TODO: Implement get() method.
if (is_null($coroutineId)) {
$coroutineId = Coroutine::getCid();
}
return Coroutine::getContext($coroutineId)[$key] ?? $defaultValue;
} }
/** /**
@@ -47,7 +55,11 @@ class CoroutineContext implements ContextInterface
*/ */
public static function exists(string $key, ?int $coroutineId = null): bool public static function exists(string $key, ?int $coroutineId = null): bool
{ {
return isset(Coroutine::getContext()[$key]); // TODO: Implement exists() method.
if (is_null($coroutineId)) {
$coroutineId = Coroutine::getCid();
}
return isset(Coroutine::getContext($coroutineId)[$key]);
} }
/** /**
@@ -57,8 +69,12 @@ class CoroutineContext implements ContextInterface
*/ */
public static function remove(string $key, ?int $coroutineId = null): void public static function remove(string $key, ?int $coroutineId = null): void
{ {
Coroutine::getContext()[$key] = null; // TODO: Implement remove() method.
unset(Coroutine::getContext()[$key]); if (is_null($coroutineId)) {
$coroutineId = Coroutine::getCid();
}
Coroutine::getContext($coroutineId)[$key] = null;
unset(Coroutine::getContext($coroutineId)[$key]);
} }
@@ -70,10 +86,13 @@ class CoroutineContext implements ContextInterface
*/ */
public static function increment(string $id, int $value = 1, ?int $coroutineId = null): int public static function increment(string $id, int $value = 1, ?int $coroutineId = null): int
{ {
if (!isset(Coroutine::getContext()[$id])) { if (is_null($coroutineId)) {
Coroutine::getContext()[$id] = 0; $coroutineId = Coroutine::getCid();
} }
return Coroutine::getContext()[$id] += $value; if (!isset(Coroutine::getContext($coroutineId)[$id])) {
Coroutine::getContext($coroutineId)[$id] = 0;
}
return Coroutine::getContext($coroutineId)[$id] += $value;
} }
/** /**
@@ -84,9 +103,12 @@ class CoroutineContext implements ContextInterface
*/ */
public static function decrement(string $id, int $value = 1, ?int $coroutineId = null): int public static function decrement(string $id, int $value = 1, ?int $coroutineId = null): int
{ {
if (!isset(Coroutine::getContext()[$id])) { if (is_null($coroutineId)) {
Coroutine::getContext()[$id] = 0; $coroutineId = Coroutine::getCid();
} }
return Coroutine::getContext()[$id] -= $value; if (!isset(Coroutine::getContext($coroutineId)[$id])) {
Coroutine::getContext($coroutineId)[$id] = 0;
}
return Coroutine::getContext($coroutineId)[$id] -= $value;
} }
} }