Skip to content

Conversation

appleboy
Copy link
Member

  • Change BusyWorkers type from uint64 to int64
  • Add CompletedTasks method to Metric interface and implementation
  • Update IncBusyWorker and DecBusyWorker to use atomic.AddInt64
  • Modify test assertions to use uint64 and int64 types
  • Change defaultWorkerCount and related functions from int to int64
  • Update NewPool and related functions to use int64 for size and worker count
  • Add CompletedTasks method to Queue and update related methods to use uint64 and int64 types

- Change `BusyWorkers` type from `uint64` to `int64`
- Add `CompletedTasks` method to `Metric` interface and implementation
- Update `IncBusyWorker` and `DecBusyWorker` to use `atomic.AddInt64`
- Modify test assertions to use `uint64` and `int64` types
- Change `defaultWorkerCount` and related functions from `int` to `int64`
- Update `NewPool` and related functions to use `int64` for size and worker count
- Add `CompletedTasks` method to `Queue` and update related methods to use `uint64` and `int64` types

Signed-off-by: appleboy <[email protected]>
@appleboy appleboy merged commit a0677b9 into master Jan 19, 2025
5 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant