1 | /**
|
---|
2 | * Copyright (c) Facebook, Inc. and its affiliates. All Rights Reserved.
|
---|
3 | *
|
---|
4 | * This source code is licensed under the MIT license found in the
|
---|
5 | * LICENSE file in the root directory of this source tree.
|
---|
6 | */
|
---|
7 | /// <reference types="node" />
|
---|
8 | import type { FarmOptions, PoolExitResult, PromiseWithCustomMessage, TaskQueue } from './types';
|
---|
9 | export { default as PriorityQueue } from './PriorityQueue';
|
---|
10 | export { default as FifoQueue } from './FifoQueue';
|
---|
11 | export { default as messageParent } from './workers/messageParent';
|
---|
12 | /**
|
---|
13 | * The Jest farm (publicly called "Worker") is a class that allows you to queue
|
---|
14 | * methods across multiple child processes, in order to parallelize work. This
|
---|
15 | * is done by providing an absolute path to a module that will be loaded on each
|
---|
16 | * of the child processes, and bridged to the main process.
|
---|
17 | *
|
---|
18 | * Bridged methods are specified by using the "exposedMethods" property of the
|
---|
19 | * "options" object. This is an array of strings, where each of them corresponds
|
---|
20 | * to the exported name in the loaded module.
|
---|
21 | *
|
---|
22 | * You can also control the amount of workers by using the "numWorkers" property
|
---|
23 | * of the "options" object, and the settings passed to fork the process through
|
---|
24 | * the "forkOptions" property. The amount of workers defaults to the amount of
|
---|
25 | * CPUS minus one.
|
---|
26 | *
|
---|
27 | * Queueing calls can be done in two ways:
|
---|
28 | * - Standard method: calls will be redirected to the first available worker,
|
---|
29 | * so they will get executed as soon as they can.
|
---|
30 | *
|
---|
31 | * - Sticky method: if a "computeWorkerKey" method is provided within the
|
---|
32 | * config, the resulting string of this method will be used as a key.
|
---|
33 | * Every time this key is returned, it is guaranteed that your job will be
|
---|
34 | * processed by the same worker. This is specially useful if your workers
|
---|
35 | * are caching results.
|
---|
36 | */
|
---|
37 | export declare class Worker {
|
---|
38 | private _ending;
|
---|
39 | private _farm;
|
---|
40 | private _options;
|
---|
41 | private _workerPool;
|
---|
42 | constructor(workerPath: string, options?: FarmOptions);
|
---|
43 | private _bindExposedWorkerMethods;
|
---|
44 | private _callFunctionWithArgs;
|
---|
45 | getStderr(): NodeJS.ReadableStream;
|
---|
46 | getStdout(): NodeJS.ReadableStream;
|
---|
47 | end(): Promise<PoolExitResult>;
|
---|
48 | }
|
---|
49 | export type { PromiseWithCustomMessage, TaskQueue };
|
---|