The below implementation may not work for me because if the semaphore is not
available then the task won't do any work. I will have to resubmit the same
task to do the work that it is supposed to do.
DonTequila wrote
> public Object execute() {
> IgniteSemaphore semaphore = this.ignite.semaphore( "123" , 1 , true,
> true);
> boolean acquired = semaphore.tryAquire();
> if (acquired) {
> // run logic
> semaphore.release();
> }
> }
Thanks,
Krish
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
