View source

class ElasticThreadPool

package sys.thread

implements IThreadPool

@:coreApi

Available on hl, macro, neko, cpp, jvm, python

Thread pool with a varying amount of threads.

A new thread is spawned every time a task is submitted while all existing threads are busy.

Constructor

@:value({ threadTimeout : 60 })new(maxThreadsCount:Int, threadTimeout:Float = 60)

Create a new thread pool with threadsCount threads.

If a worker thread does not receive a task for threadTimeout seconds it is terminated.

Variables

read onlyisShutdown:Bool

Indicates if shutdown method of this pool has been called.

maxThreadsCount:Int

read onlythreadsCount:Int

Methods

run(task:() ‑> Void):Void

Submit a task to run in a thread.

Throws an exception if the pool is shut down.

shutdown():Void

Initiates a shutdown. All previously submitted tasks will be executed, but no new tasks will be accepted.

Multiple calls to this method have no effect.