Ребята, у меня будет nodejs процесс, который будет стартовать таски

Question

Ребята, у меня будет nodejs процесс, который будет стартовать таски

(асинхронные функции). Как можно будет сделать так, чтобы можно было в любой момент остановить выполнение этой функции ? Стартовать в отдельном процессе не хочется.
Заюзать event ? Для коммуникации с главным воркером ? В главном процессе эта функция будет стартовать без await. так как нам впринципе не нужно ждать окончания выполнения этой функции..... когда закончит выполняться, тогда закончит

#javascript #programming #russian

0

04.08.2022

13 ответов

5 просмотров

Серж ИзТанзании Автор вопроса

Anton Piliugin
асинхронный функции должны быть в Promise, вы прос...

я так понимаю что этот event emitter thread safe ?

0

04.08.2022

Anton Piliugin

Серж ИзТанзании
я так понимаю что этот event emitter thread safe ?

вы видите где-то источник неприятностей?

0

04.08.2022

Demetriy Entropy

теоретически можно так function runTask(task: (resolve: (value: unknown) => void) => void) { let result: { reject?: (reason?: any) => void } = {} new Promise((resolve, reject) => { result.reject = reject; task(resolve); }) return result } без типов function runTask(task) { let result = {} new Promise((resolve, reject) => { result.reject = reject; task(resolve); }) return result }

0

04.08.2022

Anton Piliugin

Demetriy Entropy
теоретически можно так function runTask(task: (res...

а объект тут точно нужен?

0

04.08.2022

Demetriy Entropy

Anton Piliugin
а объект тут точно нужен?

хз. ts ругался на неопределённость переменной. Но вроде как присвоение должно проходить синхронно. и синхронная часть task тоже должна выполнится до return runTask

0

04.08.2022

Anton Piliugin

Demetriy Entropy
хз. ts ругался на неопределённость переменной. Но ...

reject, resolve - функции

0

04.08.2022

Demetriy Entropy

Anton Piliugin
reject, resolve - функции

закончи мысль. а то похоже мы друг друга не понимаем

0

04.08.2022

Anton Piliugin

Demetriy Entropy
закончи мысль. а то похоже мы друг друга не понима...

я вроде закончил

0

04.08.2022

Demetriy Entropy

Anton Piliugin
я вроде закончил

-_- ну тогда и я закончил :)

0

04.08.2022

Denys Mikhalenko

Demetriy Entropy
теоретически можно так function runTask(task: (res...

Вызов reject снаружи не остановит выполнение таски, даже если она асинхронная, она ведь всё равно выполнится

0

04.08.2022

Anton Piliugin

const promise = () => { let object = {} const p = new Promise((resolve, reject) => { console.log('promise is set') object.abort = reject }) object.promise = p return object } const object = promise() setTimeout(() => { console.log('setTimeout enter, aborting...') object.promise.catch((ex) => console.log(ex)) object.abort('Just abort') }, 1000)

0

04.08.2022

Denys Mikhalenko

Anton Piliugin
const promise = () => { let object = {} const ...

Это ты к чему?

0

04.08.2022

Anton Piliugin · Accepted Answer

Anton Piliugin

асинхронный функции должны быть в Promise, вы просто делаете reject, в качестве Event емиттера можно использовать https://github.com/primus/eventemitter3

0

04.08.2022

169 похожих чатов

Ребята, у меня будет nodejs процесс, который будет стартовать таски

13 ответов

Похожие вопросы