Searched defs:push_thread (Results 1 – 2 of 2) sorted by relevance
375 let push_thread = thread::spawn(move || { in test_worker_push_block() localVariable410 let push_thread = thread::spawn(move || channel.push(task_cloned)); in test_worker_close_on_push_blocked() localVariable
63 static inline void push_thread(struct thread **list, struct thread *t) in push_thread() function