syndicate-lang
/
syndicate-rs
1
0
Fork 0
Code Issues 3 Pull Requests Actions Projects Releases Wiki Activity

Small initial capacity

This commit is contained in:
Tony Garnock-Jones 2023-11-07 00:11:59 +01:00
parent f6b6dd25f1
commit 726265132f
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
syndicate/src/actor.rs
View File

@ -1566,7 +1566,7 @@ impl EventBuffer {
fn queue_for_mailbox(&mut self, mailbox: &Arc<Mailbox>) -> &mut PendingEventQueue { fn queue_for_mailbox(&mut self, mailbox: &Arc<Mailbox>) -> &mut PendingEventQueue {
if self.multiple_queues.is_some() { if self.multiple_queues.is_some() {
return &mut self.multiple_queues.as_mut().unwrap().entry(mailbox.actor_id) return &mut self.multiple_queues.as_mut().unwrap().entry(mailbox.actor_id)
.or_insert((mailbox.tx.clone(), Vec::new())).1; .or_insert((mailbox.tx.clone(), Vec::with_capacity(3))).1;
} }
if let None = self.single_queue { if let None = self.single_queue {
@ -1583,7 +1583,7 @@ impl EventBuffer {
table.insert(aid, (tx, q)); table.insert(aid, (tx, q));
self.multiple_queues = Some(table); self.multiple_queues = Some(table);
return &mut self.multiple_queues.as_mut().unwrap().entry(mailbox.actor_id) return &mut self.multiple_queues.as_mut().unwrap().entry(mailbox.actor_id)
.or_insert((mailbox.tx.clone(), Vec::new())).1; .or_insert((mailbox.tx.clone(), Vec::with_capacity(3))).1;
} }
fn commit(&mut self) { fn commit(&mut self) {