pthreads :: ThreadPool :: defaultinit
pthreads :: ThreadPool :: join_all
Join all threads, waiting for all tasks to be completedpthreads :: ThreadPool :: nb_threads
Number of threads used, can only grow after the first call toexecute
pthreads :: ThreadPool :: nb_threads=
Number of threads used, can only grow after the first call toexecute
pthreads $ ThreadPool :: SELF
Type of this instance, automatically specialized in every classcore :: Object :: class_factory
Implementation used byget_class
to create the specific class.
pthreads :: ThreadPool :: defaultinit
core :: Object :: defaultinit
core :: Object :: is_same_instance
Return true ifself
and other
are the same instance (i.e. same identity).
core :: Object :: is_same_serialized
Isself
the same as other
in a serialization context?
core :: Object :: is_same_type
Return true ifself
and other
have the same dynamic type.
pthreads :: ThreadPool :: join_all
Join all threads, waiting for all tasks to be completedpthreads :: ThreadPool :: nb_threads
Number of threads used, can only grow after the first call toexecute
pthreads :: ThreadPool :: nb_threads=
Number of threads used, can only grow after the first call toexecute
core :: Object :: output_class_name
Display class name on stdout (debug only).
# A simple ThreadPool implemented with an array
class ThreadPool
private var queue = new ConcurrentList[Task]
private var mutex = new Mutex
private var cond = new NativePthreadCond
private var threads = new Array[PoolThread]
# Number of threads used, can only grow after the first call to `execute`
var nb_threads = 5 is optional, writable
private fun create_threads do
while threads.length < nb_threads do
var t = new PoolThread(queue, mutex, cond)
t.start
threads.add t
end
end
# Adds a Task into the queue
fun execute(task: Task) do
create_threads
queue.push(task)
cond.signal
end
# Join all threads, waiting for all tasks to be completed
fun join_all do
# Wait
for t in threads do t.join
# Reset
threads.clear
end
end
lib/pthreads/threadpool.nit:21,1--54,3