Commit ce07fd9

committed

[1.1.1]

QueueManager tryAcquire interrupt self

1 parent d09e77f commit ce07fd9Copy full SHA for ce07fd9

File tree

-9

lines changed

-9

lines changed

Lines changed: 4 additions & 9 deletions

Original file line number	Diff line number	Diff line change
`@@ -29,32 +29,27 @@ public QueueManager(int size, int queueResetTimeInSec, int delayInSec) {`
`29`	`29`	`this(size, queueResetTimeInSec, delayInSec, size);`
`30`	`30`	`}`
`31`	`31`
`32`		`- public QueueManager(int size,`
`33`		`- int queueResetTimeInSec,`
`34`		`- int delayInSec,`
`35`		`- int initialSize) {`
	`32`	`+ public QueueManager(int size, int queueResetTimeInSec, int delayInSec, int initialSize) {`
`36`	`33`	`this(size,`
`37`	`34`	`(long) queueResetTimeInSec * 1000,`
`38`	`35`	`(long) delayInSec * 1000,`
`39`	`36`	`initialSize);`
`40`	`37`	`}`
`41`	`38`
`42`		`- public QueueManager(int size,`
`43`		`- long queueResetTimeInMillis,`
`44`		`- long delayInMillis,`
`45`		`- int initialSize) {`
	`39`	`+ public QueueManager(int size, long queueResetTimeInMillis, long delayInMillis, int initialSize) {`
`46`	`40`	`this.queueResetTimeInMillis = queueResetTimeInMillis;`
`47`	`41`	`this.semaphore = new Semaphore(initialSize);`
`48`	`42`	`this.executorService.scheduleAtFixedRate(releaseLocks(size), delayInMillis, queueResetTimeInMillis,`
`49`	`43`	`TimeUnit.MILLISECONDS);`
`50`	`44`	`}`
`51`	`45`
	`46`	`+ @SuppressWarnings("java:S899")`
`52`	`47`	`@Override`
`53`	`48`	`public void takeTurn() {`
`54`	`49`	`try {`
`55`	`50`	`semaphore.tryAcquire(queueResetTimeInMillis, TimeUnit.MILLISECONDS);`
`56`	`51`	`} catch (InterruptedException e) {`
`57`		`- // ignore`
	`52`	`+ Thread.currentThread().interrupt();`
`58`	`53`	`}`
`59`	`54`	`}`
`60`	`55`

Comments

(0)