1 viewer
rust 1,847,276 · typescript 232,434 · javascript 131,064 · python 19,227 · 6,362 files · digest fa0546eddd29 · built in 1.5 s · crystals off
crates/cre8-runtime-system/src/job_pool.rs
Items
const ENV_WORKER_COUNT const ENV_QUEUE_CAP const DEFAULT_WORKER_COUNT const DEFAULT_QUEUE_CAP const MAX_WORKER_COUNT const MAX_QUEUE_CAP const SHUTDOWN_JOIN_TIMEOUT_MS struct JobPoolConfig impl Default for JobPoolConfig impl JobPoolConfig enum JobPoolError impl Display for JobPoolError impl Error for JobPoolError struct JobPoolStats struct JobPoolStatsSnapshot impl JobPoolStats type BoxJob struct JobEnvelope struct JobPool impl JobPool impl Drop for JobPool
Functions
By call-graph weight (PageRank; 1.0 is the average function). 24 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| JobPool::with_defaultsrc/job_pool.rs:191 | method | 3 | 1 | 1 | 2 | 44.9 | |
| JobPool::newsrc/job_pool.rs:163 | method | 27 | 5 | 10 | 2 | 22.5 | |
| JobPoolConfig::defaultsrc/job_pool.rs:62 | trait impl | 5 | 1 | 1 | 1 | 19.6 | |
| env_usize_boundedsrc/job_pool.rs:78 | fn | 3 | 1 | 1 | 2 | 17.1 | |
| worker_loopsrc/job_pool.rs:299 | fn | 14 | 2 | 1 | 1 | 10.1 | |
| parse_bounded_usizesrc/job_pool.rs:82 | fn | 7 | 2 | 2 | 0 | 8.2 | |
| JobPool::submitsrc/job_pool.rs:206 | method | 52 | 5 | 8 | 2 | 2 | |
| JobPoolStats::snapshotsrc/job_pool.rs:132 | method | 10 | 1 | 1 | 0 | 1.4 | |
| panic_messagesrc/job_pool.rs:314 | fn | 9 | 3 | 1 | 0 | 1.4 | |
| small_poolsrc/job_pool.rs:330 | fn | 3 | 1 | 4 | 1 | 1.1 | |
| JobPool::statssrc/job_pool.rs:199 | method | 3 | 1 | 4 | 1 | 1.1 | |
| JobPool::shutdownsrc/job_pool.rs:261 | method | 6 | 1 | 1 | 1 | 0.7 | |
| JobPoolConfig::normalizedsrc/job_pool.rs:70 | method | 6 | 1 | 0 | 0 | 0.5 | |
| JobPoolError::fmtsrc/job_pool.rs:102 | trait impl | 7 | 3 | 0 | 0 | 0.5 | |
| JobPool::configsrc/job_pool.rs:195 | method | 3 | 1 | 0 | 0 | 0.5 | |
| JobPool::dropsrc/job_pool.rs:270 | trait impl | 27 | 7 | 0 | 2 | 0.5 | |
| bounded_usize_parser_clamps_extremessrc/job_pool.rs:335 | fn | 6 | 1 | 0 | 1 | 0.5 | |
| explicit_config_is_normalizedsrc/job_pool.rs:343 | fn | 8 | 1 | 0 | 2 | 0.5 | |
| submit_and_receive_resultsrc/job_pool.rs:353 | fn | 10 | 1 | 0 | 3 | 0.5 | |
| many_parallel_jobs_completesrc/job_pool.rs:365 | fn | 19 | 3 | 0 | 3 | 0.5 | |
| panic_in_job_is_caught_and_surfacedsrc/job_pool.rs:386 | fn | 19 | 2 | 0 | 3 | 0.5 | |
| queue_full_returns_error_immediatelysrc/job_pool.rs:407 | fn | 49 | 7 | 0 | 3 | 0.5 | |
| shutdown_rejects_new_submissionssrc/job_pool.rs:458 | fn | 6 | 1 | 0 | 2 | 0.5 | |
| dropped_receiver_is_fire_and_forgetsrc/job_pool.rs:466 | fn | 22 | 3 | 0 | 3 | 0.5 |
Source not readable from this process.