You're Invited:Meet the Socket Team at RSAC and BSidesSF 2026, March 23–26.RSVP →
@leafer/task
Advanced tools
@leafer/task - npm Package Compare versions
+4
-4
| { | ||
| "name": "@leafer/task", | ||
| "version": "1.0.0-beta.9", | ||
| "version": "1.0.0-beta.10", | ||
| "description": "@leafer/task", | ||
@@ -22,8 +22,8 @@ "author": "Chao (Leafer) Wan", | ||
| "dependencies": { | ||
| "@leafer/math": "1.0.0-beta.9", | ||
| "@leafer/debug": "1.0.0-beta.9" | ||
| "@leafer/math": "1.0.0-beta.10", | ||
| "@leafer/debug": "1.0.0-beta.10" | ||
| }, | ||
| "devDependencies": { | ||
| "@leafer/interface": "1.0.0-beta.9" | ||
| "@leafer/interface": "1.0.0-beta.10" | ||
| } | ||
| } |
+6
-2
| import { IFunction } from '@leafer/interface' | ||
| import { IncrementId } from '@leafer/math' | ||
| import { Debug } from '@leafer/debug' | ||
@@ -7,2 +8,3 @@ import { TaskProcessor } from './TaskProcessor' | ||
| const debug = Debug.get('TaskProcessor') | ||
| export class TaskItem { | ||
@@ -27,4 +29,6 @@ | ||
| async run(): Promise<void> { | ||
| if (this.task && !this.isComplete && this.parent.running) { | ||
| await this.task() | ||
| try { | ||
| if (this.task && !this.isComplete && this.parent.running) await this.task() | ||
| } catch (error) { | ||
| debug.error(error) | ||
| } | ||
@@ -31,0 +35,0 @@ } |
| import { IFunction, ITaskProcessor, ITaskProcessorConfig } from '@leafer/interface' | ||
| import { DataHelper } from '@leafer/data' | ||
| import { Debug } from '@leafer/debug' | ||
@@ -8,4 +7,2 @@ import { TaskItem } from './TaskItem' | ||
| const debug = Debug.get('TaskProcessor') | ||
| export class TaskProcessor implements ITaskProcessor { | ||
@@ -110,10 +107,10 @@ | ||
| public add(taskCallback: IFunction, taskTime?: number): void { | ||
| this.push(new TaskItem(taskCallback), taskTime) | ||
| public add(taskCallback: IFunction, taskTime?: number, start?: boolean,): void { | ||
| this.push(new TaskItem(taskCallback), taskTime, start) | ||
| } | ||
| public addParallel(taskCallback: IFunction, taskTime?: number): void { | ||
| public addParallel(taskCallback: IFunction, taskTime?: number, start?: boolean): void { | ||
| const task = new TaskItem(taskCallback) | ||
| task.parallel = true | ||
| this.push(task, taskTime) | ||
| this.push(task, taskTime, start) | ||
| } | ||
@@ -125,6 +122,7 @@ | ||
| private push(task: TaskItem, taskTime?: number): void { | ||
| private push(task: TaskItem, taskTime?: number, start?: boolean): void { | ||
| if (taskTime) task.taskTime = taskTime | ||
| task.parent = this | ||
| this.list.push(task) | ||
| if (start && !this.running) this.start() | ||
| } | ||
@@ -259,3 +257,2 @@ | ||
| private onParallelError(error: unknown): void { | ||
| debug.error('ParallelError') | ||
@@ -262,0 +259,0 @@ // 并行变串行, 以便下次重试 |
No alert changes
Improved metrics
- Total package byte prevSize
9310
1.55%- Lines of code
230
0.88%Dependency changes
+ Added
@leafer/debug@1.0.0-beta.10(transitive)+ Added
@leafer/math@1.0.0-beta.10(transitive)- Removed
@leafer/debug@1.0.0-beta.9(transitive)- Removed
@leafer/math@1.0.0-beta.9(transitive)Updated
@leafer/debug@1.0.0-beta.10Updated
@leafer/math@1.0.0-beta.10