MCPcopy Create free account

hub / github.com/W4G1/multithreading / functions

Functions174 in github.com/W4G1/multithreading

Method[Symbol.dispose]
()
src/lib/sync/mutex.ts:49
Method[Symbol.dispose]
()
src/lib/sync/semaphore.ts:39
Method[Symbol.dispose]
()
src/lib/sync/mpmc.ts:240
Method[Symbol.dispose]
()
src/lib/sync/mpmc.ts:351
Method[Symbol.dispose]
()
src/lib/sync/rwlock.ts:45
Method[Symbol.dispose]
()
src/lib/sync/rwlock.ts:77
Function[Symbol.hasInstance]
(instance: unknown)
src/lib/transferable.ts:38
Method[Symbol.hasInstance]
(instance)
src/node/polyfill.ts:92
Method[Symbol.iterator]
()
src/lib/json_buffer.ts:1513
Function[toDeserialized]
(_obj: unknown)
src/lib/shared.ts:60
Method[toDeserialized]
( data: ReturnType< SharedJsonBufferImpl<any>[typeof toSerialized] >[0], )
src/lib/json_buffer.ts:1482
Method[toDeserialized]
(obj: unknown)
src/lib/shared.ts:25
Method[toDeserialized]
( obj: ReturnType<Mutex<any>[typeof toSerialized]>[0], )
src/lib/sync/mutex.ts:160
Method[toDeserialized]
( buffer: ReturnType<Barrier[typeof toSerialized]>[0], )
src/lib/sync/barrier.ts:163
Method[toDeserialized]
(buffer: SharedArrayBuffer)
src/lib/sync/semaphore.ts:163
Method[toDeserialized]
( data: ReturnType<ChannelInternals<any>[typeof toSerialized]>[0], )
src/lib/sync/mpmc.ts:98
Method[toDeserialized]
( obj: ReturnType<Sender<any>[typeof toSerialized]>[0], )
src/lib/sync/mpmc.ts:247
Method[toDeserialized]
( obj: ReturnType<Receiver<any>[typeof toSerialized]>[0], )
src/lib/sync/mpmc.ts:358
Method[toDeserialized]
( obj: ReturnType<Condvar[typeof toSerialized]>[0], )
src/lib/sync/condvar.ts:81
Method[toDeserialized]
( obj: ReturnType<RwLock<any>[typeof toSerialized]>[0], )
src/lib/sync/rwlock.ts:256
Function[toSerialized]
()
src/lib/sync/mpmc.ts:125
Method[toSerialized]
()
src/lib/json_buffer.ts:1478
Method[toSerialized]
()
src/lib/sync/mutex.ts:146
Method[toSerialized]
()
src/lib/sync/barrier.ts:159
Method[toSerialized]
()
src/lib/sync/semaphore.ts:159
Method[toSerialized]
()
src/lib/sync/mpmc.ts:73
Method[toSerialized]
()
src/lib/sync/condvar.ts:77
Method[toSerialized]
()
src/lib/sync/rwlock.ts:242
Methodabort
()
src/lib/types.ts:14
MethodallocTemp
(size: number)
src/lib/json_buffer.ts:222
Methodamount
()
src/lib/sync/semaphore.ts:35
MethodblockingLock
()
src/lib/sync/mutex.ts:136
MethodblockingWait
(guard: MutexGuard<T>)
src/lib/sync/condvar.ts:30
FunctioncheckDisposed
()
src/lib/sync/mpmc.ts:121
Methodclone
()
src/lib/sync/mpmc.ts:263
Functionconstructor
(protected internals: ChannelInternals<T>)
src/lib/sync/mpmc.ts:115
Methodconstructor
()
src/browser/polyfill.ts:5
Methodconstructor
( obj: T, optionsOrBuffer?: SharedArrayBuffer | { size?: number }, )
src/lib/json_buffer.ts:128
Methodconstructor
(private buffer: SharedJsonBufferImpl<any>, ptr: number)
src/lib/json_buffer.ts:1500
Methodconstructor
(maxThreads?: number)
src/lib/pool.ts:36
Methodconstructor
(data: T, mutex: MutexController)
src/lib/sync/mutex.ts:32
Methodconstructor
(data?: T, _lockBuffer?: SharedArrayBuffer)
src/lib/sync/mutex.ts:71
Methodconstructor
(n?: number, _buffer?: SharedArrayBuffer)
src/lib/sync/barrier.ts:29
Methodconstructor
(amount: number, controller: SemaphoreController)
src/lib/sync/semaphore.ts:26
Methodconstructor
(initialCount: number, _buffer?: SharedArrayBuffer)
src/lib/sync/semaphore.ts:59
Methodconstructor
( public state: Int32Array<SharedArrayBuffer>, public items: SharedJsonBuffer<(T | null)[]>, publi
src/lib/sync/mpmc.ts:36
Methodconstructor
(_buffer?: SharedArrayBuffer)
src/lib/sync/condvar.ts:23
Methodconstructor
(data: T, controller: RwLockController)
src/lib/sync/rwlock.ts:31
Methodconstructor
(data: T, controller: RwLockController)
src/lib/sync/rwlock.ts:63
Methodconstructor
(data?: T, _stateBuffer?: SharedArrayBuffer)
src/lib/sync/rwlock.ts:100
Methodconstructor
(type: string, init?: ErrorEventInit)
src/node/polyfill.ts:19
Methodconstructor
(scriptURL: string | URL, options?: WorkerOptions)
src/node/polyfill.ts:37
Methoddispose
()
src/lib/sync/semaphore.ts:46
Methoddispose
()
src/lib/sync/rwlock.ts:52
Methoddispose
()
src/lib/sync/rwlock.ts:84
MethoddisposeError
()
src/lib/sync/mpmc.ts:140
MethoddisposeError
()
src/lib/sync/mpmc.ts:259
MethodfixupPointer
(target: Pointer)
src/lib/json_buffer.ts:348
Methodflatten
(ptr: number, currentDepth: number)
src/lib/json_buffer.ts:1266
Methodlock
()
src/lib/sync/mutex.ts:141
Methodnext
()
src/lib/json_buffer.ts:1517
MethodnotifyAll
* Wakes up all blocked threads waiting on this Condvar.
src/lib/sync/condvar.ts:72
Functionprocess
(d: Float32Array)
benchmarks/typed_arrays.bench.ts:4
FunctionreaderFn
(lock: RwLock<Uint8Array>)
test/rwlock_readers_do_not_block_readers.test.ts:15
Methodrelocate
(oldPtr: number, type: number)
src/lib/json_buffer.ts:231
Functiontask
(s: Semaphore, counter: Int32Array)
test/semaphore_rate_limiting.test.ts:14
Methodterminate
()
src/node/polyfill.ts:76
Functiontransformer
( context, )
scripts/build.ts:20
Methodvalue
()
src/lib/sync/mutex.ts:44
Methodvalue
()
src/lib/sync/rwlock.ts:40
Methodvalue
()
src/lib/sync/rwlock.ts:72
Functionvisitor
(node)
scripts/build.ts:23
FunctionworkFn
(rx: any)
test/mpmc_multiple_consumers.test.ts:13
FunctionworkerFn
(lock: RwLock<Uint8Array>, count: number)
test/rwlock_concurrent_writers.test.ts:27
← previous101–174 of 174, ranked by callers