Lines Matching defs:new
70 response_waiters: HashMap::new(),
71 empty_waiters: HashMap::new(),
78 instance.response_waiters.insert(session_id, Waiter::new());
79 instance.empty_waiters.insert(session_id, Waiter::new());
156 fn new() -> Self {
158 data_map: HashMap::new(),
159 thread_map: HashMap::new(),
160 stop_flag_map: HashMap::new(),
174 .get_or_insert_with(|| Arc::new(Mutex::new(DataQueue::new())))
203 let item = Arc::new(Mutex::new(data));
206 let mut vec = Vec::<Arc<Mutex<OutputData>>>::new();
207 let d = Arc::new(Mutex::new(data));
209 let v = Arc::new(Mutex::new(vec));
250 stop_flag_map.insert(session_id, Arc::new(Mutex::new(1)));
414 stop_flag_map.insert(session_id, Arc::new(Mutex::new(1)));
421 stop_flag_map.insert(session_id, Arc::new(Mutex::new(0)));
431 let mut remove_sessions = Vec::new();