Struct threadpool::Builder
source · pub struct Builder { /* private fields */ }
Expand description
ThreadPool
factory, which can be used in order to configure the properties of the
ThreadPool
.
The three configuration options available:
num_threads
: maximum number of threads that will be alive at any given moment by the builtThreadPool
thread_name
: thread name for each of the threads spawned by the builtThreadPool
thread_stack_size
: stack size (in bytes) for each of the threads spawned by the builtThreadPool
§Examples
Build a ThreadPool
that uses a maximum of eight threads simultaneously and each thread has
a 8 MB stack size:
let pool = threadpool::Builder::new()
.num_threads(8)
.thread_stack_size(8_000_000)
.build();
Implementations§
source§impl Builder
impl Builder
sourcepub fn num_threads(self, num_threads: usize) -> Builder
pub fn num_threads(self, num_threads: usize) -> Builder
Set the maximum number of worker-threads that will be alive at any given moment by the built
ThreadPool
. If not specified, defaults the number of threads to the number of CPUs.
§Panics
This method will panic if num_threads
is 0.
§Examples
No more than eight threads will be alive simultaneously for this pool:
use std::thread;
let pool = threadpool::Builder::new()
.num_threads(8)
.build();
for _ in 0..100 {
pool.execute(|| {
println!("Hello from a worker thread!")
})
}
sourcepub fn thread_name(self, name: String) -> Builder
pub fn thread_name(self, name: String) -> Builder
Set the thread name for each of the threads spawned by the built ThreadPool
. If not
specified, threads spawned by the thread pool will be unnamed.
§Examples
Each thread spawned by this pool will have the name “foo”:
use std::thread;
let pool = threadpool::Builder::new()
.thread_name("foo".into())
.build();
for _ in 0..100 {
pool.execute(|| {
assert_eq!(thread::current().name(), Some("foo"));
})
}
sourcepub fn thread_stack_size(self, size: usize) -> Builder
pub fn thread_stack_size(self, size: usize) -> Builder
Set the stack size (in bytes) for each of the threads spawned by the built ThreadPool
.
If not specified, threads spawned by the threadpool will have a stack size as specified in
the std::thread
documentation.
§Examples
Each thread spawned by this pool will have a 4 MB stack:
let pool = threadpool::Builder::new()
.thread_stack_size(4_000_000)
.build();
for _ in 0..100 {
pool.execute(|| {
println!("This thread has a 4 MB stack size!");
})
}
sourcepub fn build(self) -> ThreadPool
pub fn build(self) -> ThreadPool
Finalize the Builder
and build the ThreadPool
.
§Examples
let pool = threadpool::Builder::new()
.num_threads(8)
.thread_stack_size(4_000_000)
.build();
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Builder
impl RefUnwindSafe for Builder
impl Send for Builder
impl Sync for Builder
impl Unpin for Builder
impl UnwindSafe for Builder
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)