1 viewer
rust 1,961,941 · typescript 233,850 · javascript 141,145 · python 22,871 · 6,801 files · digest 6d882eacc8db · built in 12.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 | 47.2 | |
| JobPool::newsrc/job_pool.rs:163 | method | 27 | 5 | 10 | 2 | 23.5 | |
| JobPoolConfig::defaultsrc/job_pool.rs:62 | trait impl | 5 | 1 | 1 | 1 | 20.6 | |
| env_usize_boundedsrc/job_pool.rs:78 | fn | 3 | 1 | 1 | 2 | 18 | |
| worker_loopsrc/job_pool.rs:299 | fn | 14 | 2 | 1 | 1 | 10.5 | |
| parse_bounded_usizesrc/job_pool.rs:82 | fn | 7 | 2 | 2 | 0 | 8.5 | |
| 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.3 | |
| 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.