GitFireMan commented on pull request #4140: URL: https://github.com/apache/incubator-dolphinscheduler/pull/4140#issuecomment-738527037
> > @CalvinKirs When a new task put into the `queue`, sleep one second will make the comsumer waiting util one second pass. > > But use `poll(timeout,Unit)` can solve this question, and can have some performance promote when the Tasks comes low frequency. > > Also it can resolve that an always failed high-priority task block master consumer. > > Queue implement used here is `PriorityBlockingQueue` , and poll(timeout,Unit) belongs to `PriorityBlockingQueue` . > > Sorry, I think you can do this. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
