MCPcopy Create free account

hub / github.com/NthTensor/Forte / functions

Functions204 in github.com/NthTensor/Forte

Functionbaseline
(bencher: Bencher, len: usize)
benches/bevy_tasks.rs:51
Functionbevy_tasks
(bencher: Bencher, len: usize)
benches/bevy_tasks.rs:57
Functionbroadcast
Runs an operation on multiple threads and returns a vector of results. When executed on a thread that is currently registered as a worker (i.e. the c
src/thread_pool.rs:2454
Functionchili
(bencher: Bencher, nodes: (usize, usize))
benches/fork_join.rs:113
Methodclone_as_waker
Creates a new `RawWaker` from the provided pointer. # Safety Must be called with a pointer created by calling `Arc::into_raw` on an instance of `Arc
src/scope.rs:854
Methodderef
(&self)
src/thread_pool.rs:1152
Methoddrop
(&mut self)
src/thread_pool.rs:1077
Methoddrop
(&mut self)
src/unwind.rs:33
Methoddrop
(&mut self)
src/scope.rs:957
Methoddrop_as_waker
Frees the waker. # Safety Must be called with a pointer created by calling `Arc::into_raw` on an instance of `Arc<Self>` that is still alive.
src/scope.rs:905
Methodexecute
(self, worker: &Worker)
src/job.rs:70
Functionexecute_runnable
(this: NonNull<()>, _worker: &Worker)
src/thread_pool.rs:533
Functionforte
(bencher: Bencher, nodes: (usize, usize))
benches/fork_join.rs:74
Functionforte
(bencher: Bencher, size: usize)
benches/flood_fill.rs:71
Functionforte
(bencher: Bencher, size: usize)
benches/flat_scope.rs:36
Functionforte
(bencher: Bencher, len: usize)
benches/bevy_tasks.rs:84
Functionforte_chunks
( worker: &forte::Worker, data: &mut [T], func: &F, )
benches/bevy_tasks.rs:16
Methodfrom_seed
(seed: u64)
src/util.rs:32
Methodgrow
Adds the given number of threads to the thread pool. Returns the new size of the pool. The new size may be smaller than requested if all the seats in
src/thread_pool.rs:247
Methodid
(&self)
src/job.rs:64
Functionjoin_basic
()
src/thread_pool.rs:2571
Functionjoin_deep
()
src/thread_pool.rs:2586
Functionjoin_wide
()
src/thread_pool.rs:2613
Functionmain
This build-script is intentionally left blank. It exists so that cargo will let us use the `link` field, which ensures that only one version of forte
build.rs:6
Functionmain
()
benches/fork_join.rs:184
Functionmain
()
benches/flood_fill.rs:201
Functionmain
()
benches/flat_scope.rs:77
Functionmain
()
benches/bevy_tasks.rs:100
Functionmain
()
ci/src/main.rs:12
Methodmap_current
(f: F)
src/thread_pool.rs:1174
Methodmember_index
(&self)
src/thread_pool.rs:942
Methodmigrated
(&self)
src/thread_pool.rs:1504
Methodnew
()
src/thread_pool.rs:114
Methodnew
( job_pointer: NonNull<()>, execute_fn: unsafe fn(NonNull<()>, &Worker), )
src/job.rs:51
Methodnew
(init: fn() -> T)
src/lib.rs:263
Methodnew
()
src/util.rs:16
Methodnew
Creates a new latch backed by the provided semaphore.
src/latch.rs:66
Methodnew
Creates a new `ScopedFutureJob` in an `Arc`. The caller is expected to immediately call `into_job_ref` and queue it on a worker to be polled.
src/scope.rs:623
Methodnew
Creates a new [`PreparedCommand`] from a [`Cmd`] and a failure message. The other fields of [`PreparedCommand`] are filled in with their default valu
ci/src/prepare.rs:70
Methodnext_batch
(&mut self)
benches/bevy_tasks.rs:9
Functionnodes
()
benches/fork_join.rs:35
Functionnum_members
Returns the number of members participating in a thread-pool. When executed on a thread that is currently registered as a worker (i.e. the closure in
src/thread_pool.rs:2496
Methodpopulate
Ensures that there is at least one worker thread attached to the thread pool. This is mostly used to avoid deadlocks. This should be called before blo
src/thread_pool.rs:268
Methodprepare
( &self, sh: &'a xshell::Shell, _flags: Flag, )
ci/src/commands/compile_check.rs:14
Methodprepare
( &self, sh: &'a xshell::Shell, _flags: Flag, )
ci/src/commands/format.rs:14
Methodprepare
( &self, sh: &'a xshell::Shell, _flags: Flag, )
ci/src/commands/doc_check.rs:14
Methodprepare
( &self, sh: &'a xshell::Shell, flags: Flag, )
ci/src/commands/doc.rs:15
Methodprepare
( &self, sh: &'a xshell::Shell, flags: Flag, )
ci/src/commands/lints.rs:15
Methodprepare
( &self, sh: &'a xshell::Shell, _flags: Flag, )
ci/src/commands/clippy.rs:14
Methodprepare
( &self, sh: &'a xshell::Shell, flags: Flag, )
ci/src/commands/compile.rs:14
Methodprepare
( &self, sh: &'a xshell::Shell, flags: Flag, )
ci/src/commands/doc_test.rs:14
Functionrayon
(bencher: Bencher, nodes: (usize, usize))
benches/fork_join.rs:150
Functionrayon
(bencher: Bencher, size: usize)
benches/flood_fill.rs:138
Functionrayon
(bencher: Bencher, size: usize)
benches/flat_scope.rs:58
Functionrayon
(bencher: Bencher, len: usize)
benches/bevy_tasks.rs:72
Functionscope_borrow
()
src/scope.rs:1048
Functionscope_borrow_twice
()
src/scope.rs:1067
Functionscope_concurrency
()
src/scope.rs:1176
Functionscope_divide_and_conquer
()
src/scope.rs:1258
Functionscope_empty
()
src/scope.rs:998
Functionscope_future
()
src/scope.rs:1094
Functionscope_linear_stack_growth
()
src/scope.rs:1402
Functionscope_mixed_lifetimes
()
src/scope.rs:1624
Functionscope_nesting
()
src/scope.rs:1205
Functionscope_nesting_new_worker
()
src/scope.rs:1228
Functionscope_panic_propagate_from_closure
()
src/scope.rs:1449
Functionscope_panic_propagate_from_nested_scope_spawn
()
src/scope.rs:1492
Functionscope_panic_propagate_from_nested_spawn
()
src/scope.rs:1474
Functionscope_panic_propagate_from_spawn
()
src/scope.rs:1461
Functionscope_panic_propagate_still_execute_after
()
src/scope.rs:1510
Functionscope_panic_propagate_still_execute_before
()
src/scope.rs:1533
Functionscope_panic_propagate_still_execute_before_closure
()
src/scope.rs:1555
Functionscope_panic_propagate_still_execute_closure_after
()
src/scope.rs:1577
Functionscope_pending_future
()
src/scope.rs:1143
Functionscope_result
()
src/scope.rs:1009
Functionscope_sleeping_future
()
src/scope.rs:1155
Functionscope_static
()
src/scope.rs:1598
Functionscope_two
()
src/scope.rs:1024
Functionscope_update_tree
()
src/scope.rs:1311
Methodshrink
Removes the given number of threads from the thread pool. Returns the new size of the pool. See [`ThreadPool::resize`] for more information about res
src/thread_pool.rs:255
Methodsize_hint
(&self)
src/util.rs:81
Functionsizes
()
benches/flood_fill.rs:15
Functionsizes
()
benches/flat_scope.rs:12
Functionspawn_broadcast
Runs an operation on multiple threads without waiting for results. When executed on a thread that is currently registered as a worker (i.e. the closu
src/thread_pool.rs:2478
Methodspawn_broadcast
Runs an operation across multiple threads. This is like [`Worker::spawn_broadcast`], but allows the work to borrow local data.
src/scope.rs:220
Functionspawn_cancel_safety
()
src/thread_pool.rs:2559
Methodspawn_local
(&self, work: S)
src/thread_pool.rs:1601
Methodspawn_local
Like [`spawn`](Self::spawn), but accepts `!Send` work, which is confined to (and only ever polled on) the current worker's thread.
src/scope.rs:195
Functionspawn_on
Runs work on the background on a specific worker thread. This is quite similar to [`spawn`], except that the work will run on another worker instead
src/thread_pool.rs:2360
Functionspawn_then_join_in_worker
()
src/thread_pool.rs:2533
Functionspawn_then_join_outside_worker
()
src/thread_pool.rs:2547
Functionsum
(node: &Node)
benches/fork_join.rs:55
Functionthroughput_forte
(bencher: Bencher, nodes: (usize, usize))
benches/fork_join.rs:94
Functionthroughput_rayon
(bencher: Bencher, nodes: (usize, usize))
benches/fork_join.rs:168
Functionthrughput_chili
(bencher: Bencher, nodes: (usize, usize))
benches/fork_join.rs:132
Methodtree
Constructs a new binary tree with the given number of layers.
benches/fork_join.rs:19
Methodwait
(&self, seat_bitmask: u32, waiting_bitmask: &'static AtomicU32)
src/latch.rs:95
Methodwake
(self: Arc<Self>)
src/latch.rs:280
Methodwake
Queues self to be executed and consumes the waker. # Safety Must be called with a pointer created by calling `Arc::into_raw` on an instance of `Arc<
src/scope.rs:867
Methodwake_by_ref
(self: &Arc<Self>)
src/latch.rs:286
← previousnext →101–200 of 204, ranked by callers