I have opened a JIRA for the same: https://issues.apache.org/jira/browse/IGNITE-15043
Unless objections, I plan on sketching an implementation plan. On Thu, Jul 1, 2021 at 1:07 AM Atri Sharma <a...@apache.org> wrote: > > Hi All, > > I have been playing around with Collision SPI and specifically used > FifoQueueCollisionSPI and noticed that it is not really adhering to > the specified task of restricting the number of concurrent tasks that > can be run. > > Specifically, if there is only one slot available and N tasks > concurrently land onto the node, all nodes will take the current > active count, compare it with maximum jobs count and proceed. > > Essentially, we have no concurrency safety there. > > I propose refactoring FifoQueueCollisionSPI to use semaphores and/or > atomic variables to ensure that all jobs get a realistic view of the > active count. > > Please share your thoughts, > > Regards, > > Atri > > -- > Regards, > > Atri > Apache Concerted -- Regards, Atri Apache Concerted
