[Critical] Queue is skipping tasks. v0.2.0

[ievgennaida]

I have long running tasks that are extensivelly added as batches (every 30 seconds) to the basic queue example

Next queue function is used in the go func:

` err := w.QueueTask(job.TaskFunc(executableAsVariable))

After sime time pools metrics are clearly showing that queue is skipping jobs:

Example:
"BusyWorkers": 57,
"SuccessTasks": 3040,
"FailureTasks": 0,
"SubmittedTasks": 4132,

Configured workers WorkerCount": 2000,

Even if metrics are gooing to 0 busy workers, i still see a lot of pending tasks and query is not recovering them.
No error is returned when tasks are added to the queue.

1037 are lost and never will be executed Comparing to the submitted tasks metrics.
Simple test by adding tasks without actual load works fine.

Another observation that this is happening when system is running for some time.
Fresh starts are always fine.

Windows 
1.2.0

[ievgennaida]

Dear @appleboy,
Thank you for the great library.
I would try to provide a unit test to reproduce this issue, but could you please check, maybe you will find a root cause of the issue faster.
BR,
Ievgen

[appleboy]

@ievgennaida OK, Please provide some sample code to reproduce the issue.

[appleboy]

@ievgennaida Can you also try the previous version v0.1.3? The v0.2.0 is not stable so I deleted the version before.

[ievgennaida]

@appleboy Thanks for the quick reply.

I wrote a unit test that is close to the real scenario but it's pretty stable and has no issues :(

At the same time, on running systems I log a task right before adding to the queue and also 'SubmittedTasks' counter is increased but then it's ignored. Tasks are gooing offset after 10 mins or so.

"BusyWorkers": 57,
"SuccessTasks": 3040,
"FailureTasks": 0,
"SubmittedTasks": 4132

I will try to downgrade the version.

[appleboy]

At the same time, on running systems I log a task right before adding to the queue and also 'SubmittedTasks' counter is increased but then it's ignored. Tasks are gooing offset after 10 mins or so.

Any sample code for reproducing the issue.