Searched refs:thread_states (Results 1 – 2 of 2) sorted by relevance
297 thread_states: Vec<State>, field305 thread_states: (0..num_workers).map(|_| State::Working).collect(), in new()313 assert_eq!(self.thread_states[worker], State::Working); in simulate()314 self.thread_states[worker] = State::Idle; in simulate()319 self.thread_states[worker] = State::Working; in simulate()324 self.thread_states[worker] = State::Terminated; in simulate()329 assert_eq!(self.thread_states[worker], State::Idle); in simulate()330 self.thread_states[worker] = State::Sleeping; in simulate()335 assert_eq!(self.thread_states[worker], State::Notified); in simulate()336 self.thread_states[worker] = State::Idle; in simulate()[all …]
82 struct thread_state thread_states[GPR_ARRAY_SIZE(tags)]; in test_too_many_plucks() local95 thread_states[i].cc = cc; in test_too_many_plucks()96 thread_states[i].tag = tags[i]; in test_too_many_plucks()98 grpc_core::Thread("grpc_pluck_test", pluck_one, thread_states + i); in test_too_many_plucks()