repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
build: add packageManager field to package.json
[poolifier.git]
/
src
/
worker
/
abstract-worker.ts
diff --git
a/src/worker/abstract-worker.ts
b/src/worker/abstract-worker.ts
index 7e264c3799cb94b4845b03e4db73f4697c084958..12307f47c07ba019ca2da01f9547b633cfc64e03 100644
(file)
--- a/
src/worker/abstract-worker.ts
+++ b/
src/worker/abstract-worker.ts
@@
-1,6
+1,7
@@
import type { Worker } from 'node:cluster'
import type { Worker } from 'node:cluster'
-import type { MessagePort } from 'node:worker_threads'
import { performance } from 'node:perf_hooks'
import { performance } from 'node:perf_hooks'
+import type { MessagePort } from 'node:worker_threads'
+
import type {
MessageValue,
Task,
import type {
MessageValue,
Task,
@@
-13,7
+14,6
@@
import {
isAsyncFunction,
isPlainObject
} from '../utils.js'
isAsyncFunction,
isPlainObject
} from '../utils.js'
-import { KillBehaviors, type WorkerOptions } from './worker-options.js'
import type {
TaskAsyncFunction,
TaskFunction,
import type {
TaskAsyncFunction,
TaskFunction,
@@
-26,6
+26,7
@@
import {
checkValidTaskFunctionEntry,
checkValidWorkerOptions
} from './utils.js'
checkValidTaskFunctionEntry,
checkValidWorkerOptions
} from './utils.js'
+import { KillBehaviors, type WorkerOptions } from './worker-options.js'
const DEFAULT_MAX_INACTIVE_TIME = 60000
const DEFAULT_WORKER_OPTIONS: WorkerOptions = {
const DEFAULT_MAX_INACTIVE_TIME = 60000
const DEFAULT_WORKER_OPTIONS: WorkerOptions = {
@@
-127,7
+128,7
@@
export abstract class AbstractWorker<
this.taskFunctions.set(DEFAULT_TASK_NAME, boundFn)
this.taskFunctions.set(
typeof taskFunctions.name === 'string' &&
this.taskFunctions.set(DEFAULT_TASK_NAME, boundFn)
this.taskFunctions.set(
typeof taskFunctions.name === 'string' &&
- taskFunctions.name.trim().length > 0
+
taskFunctions.name.trim().length > 0
? taskFunctions.name
: 'fn1',
boundFn
? taskFunctions.name
: 'fn1',
boundFn
@@
-568,7
+569,7
@@
export abstract class AbstractWorker<
})
return undefined
})
})
return undefined
})
- .catch(
error
=> {
+ .catch(
(error: unknown)
=> {
this.sendToMainWorker({
workerError: {
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
this.sendToMainWorker({
workerError: {
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion