Compartir a través de

AsyncLock class

Paquete:
@azure/amqp-common

Constructores

AsyncLock(AsyncLockOptions)

Propiedades

DEFAULT_MAX_EXECUTION_TIME
DEFAULT_MAX_OCCUPATION_TIME
DEFAULT_MAX_PENDING
DEFAULT_TIMEOUT

Métodos

acquire<T>(string | string[], () => T | PromiseLike<T> | (done: AsyncLockDoneCallback<T>) => any, AsyncLockOptions)

Bloquear el código asincrónico.

Ejemplo

import AsyncLock = require('async-lock');
const lock = new AsyncLock();

lock.acquire(
    key,
    () => {
        // return value or promise
    },
    opts
).then(() => {
    // lock released
});
acquire<T>(string | string[], (done: AsyncLockDoneCallback<T>) => any, AsyncLockDoneCallback<T>, AsyncLockOptions)

Bloquear el código asincrónico.

Ejemplo

import AsyncLock = require('async-lock');
const lock = new AsyncLock();

lock.acquire(
    key,
    (done) => {
        // async work
        done(err, ret);
    },
    (err, ret) => {
        // lock released
    },
    opts
);
isBusy(string)

Indica si hay alguna función asincrónica en ejecución o pendiente.

Detalles del constructor

AsyncLock(AsyncLockOptions) 

new AsyncLock(options?: AsyncLockOptions)

Parámetros

options
AsyncLockOptions

Detalles de las propiedades

DEFAULT_MAX_EXECUTION_TIME 

static DEFAULT_MAX_EXECUTION_TIME: 0

Valor de propiedad

0

DEFAULT_MAX_OCCUPATION_TIME 

static DEFAULT_MAX_OCCUPATION_TIME: 0

Valor de propiedad

0

DEFAULT_MAX_PENDING 

static DEFAULT_MAX_PENDING: 1000

Valor de propiedad

1000

DEFAULT_TIMEOUT 

static DEFAULT_TIMEOUT: 0

Valor de propiedad

0

Detalles del método

acquire<T>(string | string[], () => T | PromiseLike<T> | (done: AsyncLockDoneCallback<T>) => any, AsyncLockOptions)

Bloquear el código asincrónico.

Ejemplo

import AsyncLock = require('async-lock');
const lock = new AsyncLock();

lock.acquire(
    key,
    () => {
        // return value or promise
    },
    opts
).then(() => {
    // lock released
});

function acquire<T>(key: string | string[], fn: () => T | PromiseLike<T> | (done: AsyncLockDoneCallback<T>) => any, opts?: AsyncLockOptions): Promise<T>

Parámetros

key

string | string[]

clave de recurso o claves que se van a bloquear

fn

() => T | PromiseLike<T> | (done: AsyncLockDoneCallback<T>) => any

función que se va a ejecutar

opts
AsyncLockOptions

Opciones

Devoluciones

Promise<T>

acquire<T>(string | string[], (done: AsyncLockDoneCallback<T>) => any, AsyncLockDoneCallback<T>, AsyncLockOptions)

Bloquear el código asincrónico.

Ejemplo

import AsyncLock = require('async-lock');
const lock = new AsyncLock();

lock.acquire(
    key,
    (done) => {
        // async work
        done(err, ret);
    },
    (err, ret) => {
        // lock released
    },
    opts
);

function acquire<T>(key: string | string[], fn: (done: AsyncLockDoneCallback<T>) => any, cb: AsyncLockDoneCallback<T>, opts?: AsyncLockOptions)

Parámetros

key

string | string[]

clave de recurso o claves que se van a bloquear

fn

(done: AsyncLockDoneCallback<T>) => any

función que se va a ejecutar

cb

AsyncLockDoneCallback<T>

función callback

opts
AsyncLockOptions

Opciones

isBusy(string)

Indica si hay alguna función asincrónica en ejecución o pendiente.

function isBusy(key?: string): boolean

Parámetros

key

string

Devoluciones

boolean