Cara menggunakan php thread pool example

Pooling provides a higher level abstraction of the Worker functionality, including the management of references in the way required by pthreads. From: http://php.net/manual/en/class.pool.php

Pools and workers provide an higher level of control and ease of creating multi-threaded

workName = $workName;
        printf("A new work was submitted with the name: %s\n", $workName);
    }

    public function run() {
        // This block of code in, the method, run
        // would be called by your worker.
        // All the code in this method will be executed in another thread.
        $workName = $this->workName;
        printf("Work named %s starting...\n", $workName);
        printf("New random number: %d\n", mt_rand());
    }
}

// Create an empty worker for the sake of simplicity.
class AwesomeWorker extends Worker {
    public function run() {
        // You can put some code in here, which would be executed
        // before the Work's are started (the block of code in the `run` method of your Work)
        // by the Worker.
        /* ... */
    }
}

// Create a new Pool Instance.
// The ctor of \Pool accepts two parameters.
// First: The maximum number of workers your pool can create.
// Second: The name of worker class.
$pool = new \Pool(1, \AwesomeWorker::class);

// You need to submit your jobs, rather the instance of
// the objects (works) which extends the \Threaded class.
$pool->submit(new \AwesomeWork("DeadlyWork"));
$pool->submit(new \AwesomeWork("FatalWork"));

// We need to explicitly shutdown the pool, otherwise,
// unexpected things may happen.
// See: http://stackoverflow.com/a/23600861/23602185
$pool->shutdown();

cat APIs are only intended for human consumption using the command line or Kibana console. They are not intended for use by applications. For application consumption, use the nodes info API.

Returns thread pool statistics for each node in a cluster. Returned information includes all built-in thread pools and custom thread pools.

GET /_cat/thread_pool/

GET /_cat/thread_pool

• If the Elasticsearch security features are enabled, you must have the monitor or manage to use this API.

(Optional, string) Comma-separated list of thread pool names used to limit the request. Accepts wildcard expressions.

format(Optional, string) Short version of the HTTP accept header. Valid values include JSON, YAML, etc.h

(Optional, string) Comma-separated list of column names to display.

If you do not specify which columns to include, the API returns the default columns in the order listed below. If you explicitly specify one or more columns, it only returns the specified columns.

Valid columns are:

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

id                     name    active rejected completed
0EWUhXeBQtaVGlexUeVwMg generic      0        0        70

id                     name    active rejected completed
0EWUhXeBQtaVGlexUeVwMg generic      0        0        70

id                     name    active rejected completed
0EWUhXeBQtaVGlexUeVwMg generic      0        0        70

id                     name    active rejected completed
0EWUhXeBQtaVGlexUeVwMg generic      0        0        70

id                     name    active rejected completed
0EWUhXeBQtaVGlexUeVwMg generic      0        0        70

id                     name    active rejected completed
0EWUhXeBQtaVGlexUeVwMg generic      0        0        70

id                     name    active rejected completed
0EWUhXeBQtaVGlexUeVwMg generic      0        0        70

id                     name    active rejected completed
0EWUhXeBQtaVGlexUeVwMg generic      0        0        70

id                     name    active rejected completed
0EWUhXeBQtaVGlexUeVwMg generic      0        0        70

Example with default columnsedit

The API returns the following response:

node-0 analyze             0 0 0
...
node-0 fetch_shard_started 0 0 0
node-0 fetch_shard_store   0 0 0
node-0 flush               0 0 0
...
node-0 write               0 0 0

Example with explicit columnsedit

The following API request returns the GET /_cat/thread_pool/8,

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed

id                     name    active rejected completed
0EWUhXeBQtaVGlexUeVwMg generic      0        0        70

GET /_cat/thread_pool/generic?v=true&h=id,name,active,rejected,completed