Corrutina do módulo

Módulo de control de concorrencia

coroutineO módulo proporciona unha fiberAPI para controlar a orde de execución. Permite aos desenvolvedores cambiar manualmente fiber, permitindo a multitarefa colaborativa. coroutineUnha función importante do módulo é sleepa función, que permite que o fibermódulo en execución actualmente abandone a CPU e deixe fiberfuncionar outros módulos.

Aquí tes un exemplo de código sinxelo que mostra como usar coroutineo módulo:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
const coroutine = require('coroutine');

function foo() {
    console.log('start foo');
    coroutine.sleep(1000); // enter sleep mode
    console.log('end foo');
}

function bar() {
    console.log('start bar');
    coroutine.sleep(2000);
    console.log('end bar');
}

coroutine.start(foo);
coroutine.start(bar);

No código anterior, definimos dúas funcións fooe bardespois usamos coroutine.starta función para iniciar ambas fiber. En cada fiber, usamos coroutine.sleepa función para liberar a CPU e deixar que outros fiberfuncionen.

obxecto

Lock

bloquear obxecto, verLock

1
Lock coroutine.Lock;

---

Semaphore

obxecto semáforo, véxSemaphore

1
Semaphore coroutine.Semaphore;

---

Condition

obxecto variable de condición, véxCondition

1
Condition coroutine.Condition;

---

Event

obxecto do evento, véxEvent

1
Event coroutine.Event;

---

Worker

Obxecto de traballo de fío independente, véxaseWorker

1
Worker coroutine.Worker;

función estática

start

Inicia unha fibra e devolve o obxecto de fibra

1
2
static Fiber coroutine.start(Function func,
    ...args);

Parámetros de chamada:

• func: Función, especifique a función executada pola fibra
• args: ..., unha secuencia variádica de argumentos que se pasarán á función dentro da fibra

Resultados de devolución:

• Fiber, devolve o obxecto de fibra

---

parallel

Executar un conxunto de funcións en paralelo e esperar o retorno

1
2
static Array coroutine.parallel(Array funcs,
    Integer fibers = -1);

Parámetros de chamada:

• funcs: Array, matriz de funcións executadas en paralelo
• fibers: Enteiro, limita o número de fibras concorrentes, o valor predeterminado é -1, activa o mesmo número de fibras que as funcións

Resultados de devolución:

• Array, devolve unha matriz de resultados de execución de funcións

---

Executar unha función en paralelo para procesar un conxunto de datos e esperar a devolución

1
2
3
static Array coroutine.parallel(Array datas,
    Function func,
    Integer fibers = -1);

Parámetros de chamada:

• datas: Array, matriz de datos para execución paralela
• func: Función, función executada en paralelo
• fibers: Número enteiro, limita o número de fibras concorrentes, o valor predeterminado é -1, activa o mesmo número de fibras que os datos

Resultados de devolución:

• Array, devolve unha matriz de resultados de execución de funcións

---

Executar unha función varias veces en paralelo e agardar o retorno

1
2
3
static Array coroutine.parallel(Function func,
    Integer num,
    Integer fibers = -1);

Parámetros de chamada:

• func: Función, o número de funcións executadas en paralelo
• num: Número enteiro, número de tarefas repetidas
• fibers: Enteiro, limita o número de fibras concorrentes, o valor predeterminado é -1, activa o mesmo número de fibras que as funcións

Resultados de devolución:

• Array, devolve unha matriz de resultados de execución de funcións

---

Executar un conxunto de funcións en paralelo e esperar o retorno

1
static Array coroutine.parallel(...funcs);

Parámetros de chamada:

• funcs: ..., un conxunto de funcións executadas en paralelo

Resultados de devolución:

• Array, devolve unha matriz de resultados de execución de funcións

---

current

Devolve a fibra actual

1
static Fiber coroutine.current();

Resultados de devolución:

• Fiber, o obxecto de fibra actual

---

sleep

Pausa a fibra actual durante o tempo especificado

1
static coroutine.sleep(Integer ms = 0) async;

Parámetros de chamada:

• ms: Enteiro, especifica o tempo de pausa, en milisegundos, o valor predeterminado é 0, é dicir, a operación retomarase inmediatamente cando haxa tempo.

propiedades estáticas

fibers

Matriz, devolve todas as matrices de fibra en execución

1
static readonly Array coroutine.fibers;

---

spareFibers

Enteiro, consulta e establece o estado inactivoFiberCantidade, cando o jitter do servidor é grande, o inactivo pódese aumentar adecuadamenteFibercantidade. O valor predeterminado é 256

1
static Integer coroutine.spareFibers;

---

vmid

Enteiro, consulta o actualvmnúmero de serie

1
static readonly Integer coroutine.vmid;

---

loglevel

Enteiro, modifica e consulta istovmO nivel de saída úsase para filtrar a información de saída. O predeterminado éconsole.NOTSET, saíndo todo

1
static Integer coroutine.loglevel;