[
MAINHACK
]
Mail Test
BC
Config Scan
HOME
Create...
New File
New Folder
Viewing / Editing File: PartitionedSemaphore.js
/** * @since 3.19.4 * @experimental */ import * as Effect from "./Effect.js"; import * as Iterable from "./Iterable.js"; import * as MutableHashMap from "./MutableHashMap.js"; import * as Option from "./Option.js"; /** * @since 3.19.4 * @category Models * @experimental */ export const TypeId = "~effect/PartitionedSemaphore"; /** * A `PartitionedSemaphore` is a concurrency primitive that can be used to * control concurrent access to a resource across multiple partitions identified * by keys. * * The total number of permits is shared across all partitions, with waiting * permits equally distributed among partitions using a round-robin strategy. * * This is useful when you want to limit the total number of concurrent accesses * to a resource, while still allowing for fair distribution of access across * different partitions. * * @since 3.19.4 * @category Constructors * @experimental */ export const makeUnsafe = options => { const maxPermits = Math.max(0, options.permits); if (!Number.isFinite(maxPermits)) { return { [TypeId]: TypeId, withPermits: () => effect => effect }; } let totalPermits = maxPermits; let waitingPermits = 0; const partitions = MutableHashMap.empty(); const take = (key, permits) => Effect.async(resume => { if (maxPermits < permits) { return resume(Effect.never); } else if (totalPermits >= permits) { totalPermits -= permits; return resume(Effect.void); } const needed = permits - totalPermits; const taken = permits - needed; if (totalPermits > 0) { totalPermits = 0; } waitingPermits += needed; const waiters = Option.getOrElse(MutableHashMap.get(partitions, key), () => { const set = new Set(); MutableHashMap.set(partitions, key, set); return set; }); const entry = { permits: needed, resume() { cleanup(); resume(Effect.void); } }; function cleanup() { waiters.delete(entry); if (waiters.size === 0) { MutableHashMap.remove(partitions, key); } } waiters.add(entry); return Effect.sync(() => { cleanup(); waitingPermits -= entry.permits; if (taken > 0) { releaseUnsafe(taken); } }); }); let iterator = partitions[Symbol.iterator](); const releaseUnsafe = permits => { while (permits > 0) { if (waitingPermits === 0) { totalPermits += permits; return; } let state = iterator.next(); if (state.done) { iterator = partitions[Symbol.iterator](); state = iterator.next(); if (state.done) return; } const entry = Iterable.unsafeHead(state.value[1]); entry.permits--; waitingPermits--; if (entry.permits === 0) entry.resume(); permits--; } }; return { [TypeId]: TypeId, withPermits: (key, permits) => { const takePermits = take(key, permits); const release = Effect.matchCauseEffect({ onFailure(cause) { releaseUnsafe(permits); return Effect.failCause(cause); }, onSuccess(value) { releaseUnsafe(permits); return Effect.succeed(value); } }); return effect => Effect.uninterruptibleMask(restore => Effect.flatMap(restore(takePermits), () => release(restore(effect)))); } }; }; /** * A `PartitionedSemaphore` is a concurrency primitive that can be used to * control concurrent access to a resource across multiple partitions identified * by keys. * * The total number of permits is shared across all partitions, with waiting * permits equally distributed among partitions using a round-robin strategy. * * This is useful when you want to limit the total number of concurrent accesses * to a resource, while still allowing for fair distribution of access across * different partitions. * * @since 3.19.4 * @category Constructors * @experimental */ export const make = options => Effect.sync(() => makeUnsafe(options)); //# sourceMappingURL=PartitionedSemaphore.js.map
Save Changes
Cancel / Back
Close ×
Server Info
Hostname: premium331.web-hosting.com
Server IP: 184.94.213.169
PHP Version: 8.1.34
Server Software: LiteSpeed
System: Linux premium331.web-hosting.com 4.18.0-553.80.1.lve.el8.x86_64 #1 SMP Wed Oct 22 19:29:36 UTC 2025 x86_64
HDD Total: 97.87 GB
HDD Free: 76.92 GB
Domains on IP: N/A (Requires external lookup)
System Features
Safe Mode:
Off
disable_functions:
None
allow_url_fopen:
On
allow_url_include:
Off
magic_quotes_gpc:
Off
register_globals:
Off
open_basedir:
None
cURL:
Enabled
ZipArchive:
Enabled
MySQLi:
Enabled
PDO:
Enabled
wget:
Yes
curl (cmd):
Yes
perl:
Yes
python:
Yes (py3)
gcc:
Yes
pkexec:
No
git:
Yes
User Info
Username: livedhms
User ID (UID): 1344
Group ID (GID): 1349
Script Owner UID: 1344
Current Dir Owner: 1344