Skip to content
1 viewer

rust 1,859,989 · typescript 235,537 · javascript 132,952 · python 20,426 · 6,407 files · digest 4f42637fac12 · built in 1.2 s · crystals off

crates/cre8-runtime-system/src/async_island/mod.rs

cre8-runtime-system · module async_island · src · 628 lines (463 code, 102 comment) · sha 78718cf344833a4d

Items

const ENV_WORKER_COUNT const ENV_MAX_PENDING_TASKS const DEFAULT_WORKER_COUNT const MAX_WORKER_COUNT const DEFAULT_MAX_PENDING_TASKS const MAX_PENDING_TASKS const SHUTDOWN_JOIN_TIMEOUT_MS struct AsyncIslandConfig impl Default for AsyncIslandConfig impl AsyncIslandConfig struct IslandInner struct AsyncIsland impl AsyncIsland impl Drop for AsyncIsland struct SpawnWrapper impl Future for SpawnWrapper struct NoopWake impl Wake for NoopWake

Functions

By call-graph weight (PageRank; 1.0 is the average function). 36 functions in all.

functionkindlinescyclomaticcallerscalleesweightcrystal
AsyncIsland::with_job_poolsrc/async_island/mod.rs:161method311245.1
AsyncIsland::newsrc/async_island/mod.rs:125method314220.9
AsyncIslandConfig::defaultsrc/async_island/mod.rs:65trait impl711219.6
AsyncIsland::new_with_max_pendingsrc/async_island/mod.rs:129method315329.6
max_pending_tasks_from_envsrc/async_island/mod.rs:88fn61129.4
parse_bounded_worker_countsrc/async_island/mod.rs:80fn72209.3
parse_bounded_max_pending_taskssrc/async_island/mod.rs:95fn72204.9
worker_loopsrc/async_island/mod.rs:327fn173134.6
AsyncIsland::spawn_innersrc/async_island/mod.rs:188method275243
AsyncIsland::block_onsrc/async_island/mod.rs:219method1711212.4
islandsrc/async_island/mod.rs:432fn41822
AsyncIsland::spawn_blockingsrc/async_island/mod.rs:244method333431.4
panic_messagesrc/async_island/mod.rs:390fn93201.3
AsyncIsland::try_reserve_pending_slotsrc/async_island/mod.rs:287method123101.1
AsyncIsland::shutdownsrc/async_island/mod.rs:281method51110.7
AsyncIsland::max_pending_taskssrc/async_island/mod.rs:169method31100.6
AsyncIsland::pending_taskssrc/async_island/mod.rs:173method31100.6
AsyncIslandConfig::normalizedsrc/async_island/mod.rs:75method31000.5
AsyncIsland::configsrc/async_island/mod.rs:165method31000.5
AsyncIsland::spawnsrc/async_island/mod.rs:180method71010.5
AsyncIsland::dropsrc/async_island/mod.rs:302trait impl237020.5
SpawnWrapper::pollsrc/async_island/mod.rs:356trait impl326010.5
worker_count_parser_clamps_extremessrc/async_island/mod.rs:438fn61010.5
block_on_resolves_simple_futuresrc/async_island/mod.rs:451fn51020.5
max_pending_parser_clamps_extremessrc/async_island/mod.rs:458fn61010.5
spawn_returns_join_handle_with_resultsrc/async_island/mod.rs:466fn61020.5
explicit_config_is_normalizedsrc/async_island/mod.rs:474fn91030.5
join_handle_is_finished_after_completionsrc/async_island/mod.rs:485fn133020.5
spawn_over_pending_cap_returns_cancelled_handlesrc/async_island/mod.rs:500fn251040.5
NoopWake::wakesrc/async_island/mod.rs:506trait impl11000.5
pending_task_without_retained_waker_releases_slotsrc/async_island/mod.rs:527fn173040.5
spawn_blocking_runs_on_dispatch_and_resolvessrc/async_island/mod.rs:546fn151030.5
spawned_panic_surfaces_as_join_errorsrc/async_island/mod.rs:563fn122020.5
spawn_blocking_panic_surfaces_as_join_errorsrc/async_island/mod.rs:577fn122030.5
many_spawns_completesrc/async_island/mod.rs:591fn163020.5
many_spawn_blocking_complete_via_dispatchsrc/async_island/mod.rs:609fn193030.5

Source not readable from this process.