repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
chore: v2.6.24
[poolifier.git]
/
src
/
pools
/
abstract-pool.ts
diff --git
a/src/pools/abstract-pool.ts
b/src/pools/abstract-pool.ts
index eb47bc2f24f67b983b4829a763705c6fb8b45828..b48608372574bc5c5af41332e9d85601a8224c95 100644
(file)
--- a/
src/pools/abstract-pool.ts
+++ b/
src/pools/abstract-pool.ts
@@
-28,13
+28,12
@@
import {
PoolTypes,
type TasksQueueOptions
} from './pool'
PoolTypes,
type TasksQueueOptions
} from './pool'
-import {
- type IWorker,
- type IWorkerNode,
- type WorkerInfo,
- type WorkerType,
- WorkerTypes,
- type WorkerUsage
+import type {
+ IWorker,
+ IWorkerNode,
+ WorkerInfo,
+ WorkerType,
+ WorkerUsage
} from './worker'
import {
type MeasurementStatisticsRequirements,
} from './worker'
import {
type MeasurementStatisticsRequirements,
@@
-1171,13
+1170,7
@@
export abstract class AbstractPool<
*/
private executeTask (workerNodeKey: number, task: Task<Data>): void {
this.beforeTaskExecutionHook(workerNodeKey, task)
*/
private executeTask (workerNodeKey: number, task: Task<Data>): void {
this.beforeTaskExecutionHook(workerNodeKey, task)
- this.sendToWorker(
- workerNodeKey,
- task,
- this.worker === WorkerTypes.thread && task.transferList != null
- ? task.transferList
- : undefined
- )
+ this.sendToWorker(workerNodeKey, task, task.transferList)
}
private enqueueTask (workerNodeKey: number, task: Task<Data>): number {
}
private enqueueTask (workerNodeKey: number, task: Task<Data>): number {