Mirrors/servo
1
0
Fork 0
mirror of https://github.com/servo/servo.git synced 2025-08-05 05:30:08 +01:00
Code Issues Projects Releases Packages Wiki Activity

Addressed code review comments.

Browse source
This commit is contained in:
Clark Gaebel 2014-10-27 14:19:44 -07:00
parent b0d16462ff
commit 293969cb7d
1 changed files with 11 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

16
components/util/workqueue.rs
View file

@ -71,7 +71,9 @@ struct WorkerThread<QueueData, WorkData> {
rng: XorShiftRng, rng: XorShiftRng,
} }
static SPIN_COUNT: uint = 128; static SPIN_COUNT: u32 = 128;
static SPINS_UNTIL_BACKOFF: u32 = 100;
static BACKOFF_INCREMENT_IN_US: u32 = 5;
impl<QueueData: Send, WorkData: Send> WorkerThread<QueueData, WorkData> { impl<QueueData: Send, WorkData: Send> WorkerThread<QueueData, WorkData> {
/// The main logic. This function starts up the worker and listens for /// The main logic. This function starts up the worker and listens for
@ -85,10 +87,11 @@ impl<QueueData: Send, WorkData: Send> WorkerThread<QueueData, WorkData> {
ExitMsg => return, ExitMsg => return,
}; };
let mut back_off_sleep = 0 as u32;
// We're off! // We're off!
// //
// FIXME(pcwalton): Can't use labeled break or continue cross-crate due to a Rust bug. // FIXME(pcwalton): Can't use labeled break or continue cross-crate due to a Rust bug.
let mut back_off_sleep = 0 as u32;
loop { loop {
// FIXME(pcwalton): Nasty workaround for the lack of labeled break/continue // FIXME(pcwalton): Nasty workaround for the lack of labeled break/continue
// cross-crate. // cross-crate.
@ -114,10 +117,13 @@ impl<QueueData: Send, WorkData: Send> WorkerThread<QueueData, WorkData> {
} }
} }
if (i>100) { if i > SPINS_UNTIL_BACKOFF {
unsafe {usleep(back_off_sleep as u32)}; unsafe {
back_off_sleep = back_off_sleep + 5; usleep(back_off_sleep as u32);
}
back_off_sleep += BACKOFF_INCREMENT_IN_US;
} }
if i == SPIN_COUNT { if i == SPIN_COUNT {
match self.port.try_recv() { match self.port.try_recv() {
Ok(StopMsg) => { Ok(StopMsg) => {