tokio-rs/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2026-08-29 00:00:11 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #126 from dwrensha/slab-capacity-one

Browse Source 
initialize slabs with capacity of one
This commit is contained in:
Alex Crichton
2016-12-16 11:07:17 -08:00
committed by GitHub
parent f036691681 7abe6db0ae
commit e0990e8a5a
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/reactor/mod.rs
+3 -5
View File
@@ -35,8 +35,6 @@ pub use self::interval::Interval;
static NEXT_LOOP_ID: AtomicUsize = ATOMIC_USIZE_INIT; static NEXT_LOOP_ID: AtomicUsize = ATOMIC_USIZE_INIT;
scoped_thread_local!(static CURRENT_LOOP: Core); scoped_thread_local!(static CURRENT_LOOP: Core);
const SLAB_CAPACITY: usize = 1024 * 64;
/// An event loop. /// An event loop.
/// ///
/// The event loop is the main source of blocking in an application which drives /// The event loop is the main source of blocking in an application which drives
@@ -154,9 +152,9 @@ impl Core {
inner: Rc::new(RefCell::new(Inner { inner: Rc::new(RefCell::new(Inner {
id: NEXT_LOOP_ID.fetch_add(1, Ordering::Relaxed), id: NEXT_LOOP_ID.fetch_add(1, Ordering::Relaxed),
io: io, io: io,
io_dispatch: Slab::with_capacity(SLAB_CAPACITY), io_dispatch: Slab::with_capacity(1),
task_dispatch: Slab::with_capacity(SLAB_CAPACITY), task_dispatch: Slab::with_capacity(1),
timeouts: Slab::with_capacity(SLAB_CAPACITY), timeouts: Slab::with_capacity(1),
timer_heap: Heap::new(), timer_heap: Heap::new(),
})), })),
}) })