Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/W4G1/multithreading
/ functions
Functions
174 in github.com/W4G1/multithreading
⨍
Functions
174
◇
Types & classes
53
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
Method
abort
()
src/lib/types.ts:14
Method
allocTemp
(size: number)
src/lib/json_buffer.ts:222
Method
amount
()
src/lib/sync/semaphore.ts:35
Method
blockingLock
()
src/lib/sync/mutex.ts:136
Method
blockingWait
(guard: MutexGuard<T>)
src/lib/sync/condvar.ts:30
Function
checkDisposed
()
src/lib/sync/mpmc.ts:121
Method
clone
()
src/lib/sync/mpmc.ts:263
Function
constructor
(protected internals: ChannelInternals<T>)
src/lib/sync/mpmc.ts:115
Method
constructor
()
src/browser/polyfill.ts:5
Method
constructor
( obj: T, optionsOrBuffer?: SharedArrayBuffer | { size?: number }, )
src/lib/json_buffer.ts:128
Method
constructor
(private buffer: SharedJsonBufferImpl<any>, ptr: number)
src/lib/json_buffer.ts:1500
Method
constructor
(maxThreads?: number)
src/lib/pool.ts:36
Method
constructor
(data: T, mutex: MutexController)
src/lib/sync/mutex.ts:32
Method
constructor
(data?: T, _lockBuffer?: SharedArrayBuffer)
src/lib/sync/mutex.ts:71
Method
constructor
(n?: number, _buffer?: SharedArrayBuffer)
src/lib/sync/barrier.ts:29
Method
constructor
(amount: number, controller: SemaphoreController)
src/lib/sync/semaphore.ts:26
Method
constructor
(initialCount: number, _buffer?: SharedArrayBuffer)
src/lib/sync/semaphore.ts:59
Method
constructor
( public state: Int32Array<SharedArrayBuffer>, public items: SharedJsonBuffer<(T | null)[]>, publi
src/lib/sync/mpmc.ts:36
Method
constructor
(_buffer?: SharedArrayBuffer)
src/lib/sync/condvar.ts:23
Method
constructor
(data: T, controller: RwLockController)
src/lib/sync/rwlock.ts:31
Method
constructor
(data: T, controller: RwLockController)
src/lib/sync/rwlock.ts:63
Method
constructor
(data?: T, _stateBuffer?: SharedArrayBuffer)
src/lib/sync/rwlock.ts:100
Method
constructor
(type: string, init?: ErrorEventInit)
src/node/polyfill.ts:19
Method
constructor
(scriptURL: string | URL, options?: WorkerOptions)
src/node/polyfill.ts:37
Method
dispose
()
src/lib/sync/semaphore.ts:46
Method
dispose
()
src/lib/sync/rwlock.ts:52
Method
dispose
()
src/lib/sync/rwlock.ts:84
Method
disposeError
()
src/lib/sync/mpmc.ts:140
Method
disposeError
()
src/lib/sync/mpmc.ts:259
Method
fixupPointer
(target: Pointer)
src/lib/json_buffer.ts:348
Method
flatten
(ptr: number, currentDepth: number)
src/lib/json_buffer.ts:1266
Method
lock
()
src/lib/sync/mutex.ts:141
Method
next
()
src/lib/json_buffer.ts:1517
Method
notifyAll
* Wakes up all blocked threads waiting on this Condvar.
src/lib/sync/condvar.ts:72
Function
process
(d: Float32Array)
benchmarks/typed_arrays.bench.ts:4
Function
readerFn
(lock: RwLock<Uint8Array>)
test/rwlock_readers_do_not_block_readers.test.ts:15
Method
relocate
(oldPtr: number, type: number)
src/lib/json_buffer.ts:231
Function
task
(s: Semaphore, counter: Int32Array)
test/semaphore_rate_limiting.test.ts:14
Method
terminate
()
src/node/polyfill.ts:76
Function
transformer
( context, )
scripts/build.ts:20
Method
value
()
src/lib/sync/mutex.ts:44
Method
value
()
src/lib/sync/rwlock.ts:40
Method
value
()
src/lib/sync/rwlock.ts:72
Function
visitor
(node)
scripts/build.ts:23
Function
workFn
(rx: any)
test/mpmc_multiple_consumers.test.ts:13
Function
workerFn
(lock: RwLock<Uint8Array>, count: number)
test/rwlock_concurrent_writers.test.ts:27
← previous
101–174 of 174, ranked by callers