Functions — github.com/W4G1/multithreading

hub / github.com/W4G1/multithreading / functions

Functions174 in github.com/W4G1/multithreading

⨍ Functions 174◇ Types & classes 53

↓ 65 callersFunctionspawn

(arg1: any, arg2?: any)

src/lib/lib.ts:74

↓ 62 callersMethodjoin

()

src/lib/types.ts:13

↓ 60 callersFunctionmove

(...args: Args)

src/lib/lib.ts:48

↓ 30 callersMethodresolvePtr

(ptr: number)

src/lib/json_buffer.ts:366

↓ 25 callersMethodsend

(value: T)

src/lib/sync/mpmc.ts:150

↓ 21 callersMethodrecv

()

src/lib/sync/mpmc.ts:269

↓ 19 callersFunctionpatchDynamicImports

( code: string, callerLocation: string, )

src/lib/patch_import.ts:5

↓ 16 callersFunctionchannel

(capacity: number = 32, options?: { size?: number })

src/lib/sync/mpmc.ts:365

↓ 14 callersMethodreadSlot

(offset: number)

src/lib/json_buffer.ts:456

↓ 14 callersMethodwait

* Asynchronously waits until all participating threads have reached the barrier.

src/lib/sync/barrier.ts:130

↓ 13 callersMethodreadString

(ptr: number)

src/lib/json_buffer.ts:387

↓ 13 callersFunctionwrapStandard

(argCode: string)

test/patch_import.test.ts:14

↓ 11 callersMethodblockingWait

* Blocks the current thread until all participating threads have reached the barrier.

src/lib/sync/barrier.ts:100

↓ 11 callersFunctiondeserialize

(envelope: Envelope)

src/lib/shared.ts:113

↓ 10 callersFunctionserialize

( arg: any, )

src/lib/shared.ts:73

↓ 10 callersMethodterminate

()

src/lib/pool.ts:213

↓ 9 callersMethodblockingAcquire

(amount = 1)

src/lib/sync/semaphore.ts:108

↓ 9 callersFunctionregister

(typeId: number, cls: SerializableConstructor)

src/lib/shared.ts:68

↓ 8 callersMethodacquire

(amount = 1)

src/lib/sync/semaphore.ts:131

↓ 8 callersMethodisClosed

()

src/lib/sync/mpmc.ts:65

↓ 8 callersMethodlock

()

src/lib/sync/mutex.ts:23

↓ 7 callersMethodalloc

(byteSize: number, retry = true)

src/lib/json_buffer.ts:190

↓ 7 callersMethodclose

()

src/lib/sync/mpmc.ts:220

↓ 7 callersMethodpostMessage

(message: any, transfer: Transferable[])

src/node/polyfill.ts:72

↓ 7 callersMethodrelease

(amount: number)

src/lib/sync/semaphore.ts:13

↓ 6 callersMethodarraySpliceImpl

( target: Pointer, start: number, deleteCount: number, items: any[] = [], )

src/lib/json_buffer.ts:1123

↓ 6 callersMethodblockingLock

()

src/lib/sync/mutex.ts:22

↓ 6 callersMethodclone

()

src/lib/sync/mpmc.ts:144

↓ 6 callersMethodread

()

src/lib/sync/rwlock.ts:165

↓ 6 callersFunctionshutdown

()

src/lib/lib.ts:129

↓ 6 callersMethodtryAcquire

(amount = 1)

src/lib/sync/semaphore.ts:90

↓ 4 callersMethod#unlock

()

src/lib/sync/barrier.ts:64

↓ 4 callersMethodarraySet

(target: Pointer, index: number, value: any)

src/lib/json_buffer.ts:1411

↓ 4 callersFunctioninitRuntime

(config: { maxWorkers: number })

src/lib/lib.ts:29

↓ 4 callersMethodobjectSet

(target: Pointer, key: string, value: any)

src/lib/json_buffer.ts:991

↓ 4 callersFunctionworkerOverride

(fn: () => Worker)

src/lib/pool.ts:15

↓ 4 callersMethodwriteValue

(value: any)

src/lib/json_buffer.ts:481

↓ 3 callersFunctioncountUtf8Bytes

(str: string)

src/lib/json_buffer.ts:74

↓ 3 callersMethoddispose

()

src/lib/sync/mutex.ts:56

↓ 3 callersFunctionhashPassword

(password: string)

examples/password_hashing.ts:3

↓ 3 callersFunctiontask

(id: number, delayMs: number)

test/barrier.test.ts:223

↓ 3 callersMethodunlock

()

src/lib/sync/mutex.ts:21

↓ 3 callersFunctionwarnUnsafe

()

src/lib/check_move_args.ts:15

↓ 3 callersMethodwrite

()

src/lib/sync/rwlock.ts:217

↓ 2 callersMethod#performAsyncLock

* Shared logic for async lock. * Used by both public lock() and the Controller (for Condvar)

src/lib/sync/mutex.ts:126

↓ 2 callersMethod#performBlockingLock

* Shared logic for blocking lock. * Used by both public blockingLock() and the Controller (for Condvar)

src/lib/sync/mutex.ts:115

↓ 2 callersMethod#tryLock

()

src/lib/sync/mutex.ts:84

↓ 2 callersMethodallocArray

(initialCap: number)

src/lib/json_buffer.ts:577

↓ 2 callersMethodallocObject

(initialCap: number)

src/lib/json_buffer.ts:566

↓ 2 callersMethodarrayEnsureCapacity

(target: Pointer, minCap: number)

src/lib/json_buffer.ts:1088

↓ 2 callersMethodblockingRecv

()

src/lib/sync/mpmc.ts:297

↓ 2 callersMethodblockingSend

(value: T)

src/lib/sync/mpmc.ts:185

↓ 2 callersFunctionfib

(n: number)

benchmarks/fibonacci.bench.ts:5

↓ 2 callersMethodgetProxyForPtr

(ptr: number)

src/lib/json_buffer.ts:823

↓ 2 callersFunctiongetTrackedCount

()

test/json_buffer_leak_check.test.ts:14

↓ 2 callersMethodhasReceivers

()

src/lib/sync/mpmc.ts:69

↓ 2 callersMethodinitViews

()

src/lib/json_buffer.ts:150

↓ 2 callersMethodinitializeBuffer

(obj: T)

src/lib/json_buffer.ts:156

↓ 2 callersMethodread

()

src/lib/sync/mpmc.ts:53

↓ 2 callersFunctionsearch

( data: Int8Array, pattern: number[], start: number, end: number, )

benchmarks/pattern_search.bench.ts:12

↓ 2 callersMethodtoArrayShallow

* Helper to create a shallow JS Array containing Proxies or primitives * derived from the underlying buffer.

src/lib/json_buffer.ts:1198

↓ 2 callersMethodtoConsoleView

(ptr: number, depth = 0)

src/lib/json_buffer.ts:861

↓ 2 callersMethodtoJSON

(ptr: number)

src/lib/json_buffer.ts:917

↓ 2 callersMethodunlock

()

src/lib/sync/rwlock.ts:16

↓ 2 callersFunctionwrapRoot

(argCode: string)

test/patch_import.test.ts:24

↓ 2 callersMethodwrite

(value: T)

src/lib/sync/mpmc.ts:47

↓ 1 callersMethod#lock

* Internal Spin/Wait Lock for protecting state updates. * Updates are very fast, so we use a simple atomic lock mechanism.

src/lib/sync/barrier.ts:51

↓ 1 callersMethod#lockAsync

* Async version of the internal lock for Main Thread compatibility.

src/lib/sync/barrier.ts:81

↓ 1 callersMethod#release

* Internal release logic used by the Controller/Guard

src/lib/sync/semaphore.ts:82

↓ 1 callersMethod#unlock

()

src/lib/sync/mutex.ts:96

↓ 1 callersMethod#unlockRead

()

src/lib/sync/rwlock.ts:112

↓ 1 callersMethod#unlockWrite

()

src/lib/sync/rwlock.ts:120

↓ 1 callersMethodblockingRead

()

src/lib/sync/rwlock.ts:141

↓ 1 callersMethodblockingWrite

()

src/lib/sync/rwlock.ts:194

↓ 1 callersFunctioncheckMoveArgs

(args: any[])

src/lib/check_move_args.ts:19

↓ 1 callersMethodclose

()

src/lib/sync/mpmc.ts:345

↓ 1 callersMethodcollectGarbage

()

src/lib/json_buffer.ts:213

↓ 1 callersMethodcreateWorker

(index: number)

src/lib/pool.ts:74

↓ 1 callersFunctiondrop

(resource: T)

src/lib/lib.ts:59

↓ 1 callersFunctionfindArgumentBounds

(code: string, startIndex: number)

src/lib/patch_import.ts:110

↓ 1 callersFunctiongetCallerLocation

()

src/lib/caller_location.ts:22

↓ 1 callersFunctiongetPool

()

src/lib/lib.ts:34

↓ 1 callersMethodgetRootProxy

()

src/lib/json_buffer.ts:185

↓ 1 callersFunctioninitConsoleHooks

()

src/lib/json_buffer.ts:34

↓ 1 callersFunctionkeepAlive

()

src/deno/polyfill.ts:49

↓ 1 callersMethodnotifyOne

* Wakes up one blocked thread waiting on this Condvar.

src/lib/sync/condvar.ts:64

↓ 1 callersMethodnukeWorker

(index: number)

src/lib/pool.ts:114

↓ 1 callersMethodobjectDelete

(target: Pointer, key: string)

src/lib/json_buffer.ts:957

↓ 1 callersMethodprocessArgs

(args: any[])

src/lib/pool.ts:52

↓ 1 callersFunctionrun

()

benchmarks/invokation_throughput.bench.ts:15

↓ 1 callersMethodsubmit

(task: ThreadTask)

src/lib/pool.ts:123

↓ 1 callersFunctionsum

(a: number, b: number)

examples/function_in_same_file.ts:4

↓ 1 callersMethodwait

* Asynchronously waits for a notification. Safe to use on the Main Thread. * @param guard The MutexGuard protecting the shared state.

src/lib/sync/condvar.ts:45

↓ 1 callersMethodwriteInitial

(target: Pointer, data: any)

src/lib/json_buffer.ts:588

Method[INTERNAL_MUTEX_CONTROLLER]

* Internal accessor for Condvar support

src/lib/sync/mutex.ts:40

Method[INTERNAL_RWLOCK_CONTROLLER]

()

src/lib/sync/rwlock.ts:36

Method[INTERNAL_RWLOCK_CONTROLLER]

()

src/lib/sync/rwlock.ts:68

Method[INTERNAL_SEMAPHORE_CONTROLLER]

()

src/lib/sync/semaphore.ts:31

Method[INTERNAL_SEMAPHORE_CONTROLLER]

()

src/lib/sync/semaphore.ts:75

Method[Symbol.asyncIterator]

()

src/lib/sync/mpmc.ts:327

next →1–100 of 174, ranked by callers