17e3775b23
This fixes a hang found while testing the jQuery test suite. Source-Repo: https://github.com/servo/servo Source-Revision: c51e9f04559f04f1e820b792261e1653c6869ee5
45 lines
1.4 KiB
Rust
45 lines
1.4 KiB
Rust
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
use std::borrow::ToOwned;
|
|
use task_state;
|
|
use std::thread;
|
|
use std::sync::mpsc::Sender;
|
|
use std::thread::Builder;
|
|
|
|
pub fn spawn_named<F>(name: String, f: F)
|
|
where F: FnOnce() + Send + 'static
|
|
{
|
|
let builder = thread::Builder::new().name(name);
|
|
builder.spawn(move || {
|
|
f()
|
|
}).unwrap();
|
|
}
|
|
|
|
/// Arrange to send a particular message to a channel if the task fails.
|
|
pub fn spawn_named_with_send_on_failure<F, T>(name: String,
|
|
state: task_state::TaskState,
|
|
f: F,
|
|
msg: T,
|
|
dest: Sender<T>)
|
|
where F: FnOnce() + Send + 'static,
|
|
T: Send + 'static
|
|
{
|
|
let future_handle = thread::Builder::new().name(name.to_owned()).spawn(move || {
|
|
task_state::initialize(state);
|
|
f()
|
|
}).unwrap();
|
|
|
|
let watcher_name = format!("{}Watcher", name);
|
|
Builder::new().name(watcher_name).spawn(move || {
|
|
match future_handle.join() {
|
|
Ok(()) => (),
|
|
Err(..) => {
|
|
debug!("{} failed, notifying constellation", name);
|
|
dest.send(msg).unwrap();
|
|
}
|
|
}
|
|
}).unwrap();
|
|
}
|