WorkerSyncFunction
} from '../utility-types'
import { EMPTY_FUNCTION, isPlainObject } from '../utils'
-import type { KillBehavior, WorkerOptions } from './worker-options'
-import { KillBehaviors } from './worker-options'
+import {
+ type KillBehavior,
+ KillBehaviors,
+ type WorkerOptions
+} from './worker-options'
const DEFAULT_FUNCTION_NAME = 'default'
const DEFAULT_MAX_INACTIVE_TIME = 60000
super(type)
this.checkWorkerOptions(this.opts)
this.checkTaskFunctions(taskFunctions)
- if (
- !this.isMain &&
- (this.opts.maxInactiveTime ?? DEFAULT_MAX_INACTIVE_TIME) > 0
- ) {
+ if (!this.isMain) {
this.lastTaskTimestamp = performance.now()
this.aliveInterval = setInterval(
this.checkAlive.bind(this),
const runTime = performance.now() - startTimestamp
this.sendToMainWorker({
data: res,
- id: message.id,
runTime,
- waitTime
+ waitTime,
+ id: message.id
})
} catch (e) {
const err = this.handleError(e as Error)
- this.sendToMainWorker({ error: err, id: message.id })
+ this.sendToMainWorker({
+ error: err,
+ errorData: message.data,
+ id: message.id
+ })
} finally {
!this.isMain && (this.lastTaskTimestamp = performance.now())
}
const runTime = performance.now() - startTimestamp
this.sendToMainWorker({
data: res,
- id: message.id,
runTime,
- waitTime
+ waitTime,
+ id: message.id
})
return null
})
.catch(e => {
const err = this.handleError(e as Error)
- this.sendToMainWorker({ error: err, id: message.id })
+ this.sendToMainWorker({
+ error: err,
+ errorData: message.data,
+ id: message.id
+ })
})
.finally(() => {
!this.isMain && (this.lastTaskTimestamp = performance.now())