Home
last modified time | relevance | path

Searched refs:finished (Results 1 - 4 of 4) sorted by relevance

/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
H A Dhttp_body.rs284 let mut finished = false; in merge_chunks() variables
289 finished = true; in merge_chunks()
293 finished = true; in merge_chunks()
301 if finished && !junk.is_empty() { in merge_chunks()
317 Ok((idx, finished)) in merge_chunks()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dcurrent_thread.rs424 let finished = Arc::new(AtomicUsize::new(0)); in ut_current_thread_run_queue()
426 let finished_clone = finished.clone(); in ut_current_thread_run_queue()
434 let finished_clone = finished.clone(); in ut_current_thread_run_queue()
451 assert_eq!(finished.load(Acquire), 2); in ut_current_thread_run_queue()
453 let finished_clone = finished.clone(); in ut_current_thread_run_queue()
461 let finished_clone = finished.clone(); in ut_current_thread_run_queue()
471 assert_eq!(finished.load(Acquire), 4); in ut_current_thread_run_queue()
H A Dasync_pool.rs399 let mut finished = lock.lock().unwrap(); in async_thread_proc() variables
400 *finished += 1; in async_thread_proc()
403 if *finished >= inner.total { in async_thread_proc()
570 let finished = lock.lock().unwrap(); in release_wait()
572 .wait_timeout_while(finished, ASYNC_THREAD_QUIT_WAIT_TIME, |&mut finished| { in release_wait()
573 finished < total in release_wait()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
H A Dspawn.rs40 // Task won't be polled again after finished in poll()
41 let func = self.0.take().expect("blocking tasks cannot be polled after finished"); in poll()

Completed in 4 milliseconds