Skip to content

Commit 5321c47

Browse files
committed
use correct idiom for lock()/unlock() (see javadoc for java.util.concurrent.locks.Lock) - Fortify
1 parent 99fbf53 commit 5321c47

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

visualvm/core/src/org/graalvm/visualvm/core/scheduler/SchedulingPipe.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,8 @@ final class SchedulingPipe {
6868
}
6969

7070
void addTask(DefaultScheduledTask task) {
71+
tasksLock.writeLock().lock();
7172
try {
72-
tasksLock.writeLock().lock();
7373
if (tasks.isEmpty()) {
7474
startPipe();
7575
}
@@ -84,8 +84,8 @@ private void startPipe() {
8484
pipeFuture = schedulerService.scheduleAtFixedRate(new Runnable() {
8585

8686
public void run() {
87+
tasksLock.writeLock().lock();
8788
try {
88-
tasksLock.writeLock().lock();
8989
final long timeStamp = System.currentTimeMillis();
9090
for (Iterator<WeakReference<DefaultScheduledTask>> iter = tasks.iterator(); iter.hasNext();) {
9191
WeakReference<DefaultScheduledTask> ref = iter.next();
@@ -120,8 +120,8 @@ public void run() {
120120
}
121121

122122
void removeTask(DefaultScheduledTask task) {
123+
tasksLock.writeLock().lock();
123124
try {
124-
tasksLock.writeLock().lock();
125125
for(Iterator<WeakReference<DefaultScheduledTask>> iter = tasks.iterator();iter.hasNext();) {
126126
WeakReference<DefaultScheduledTask> ref = iter.next();
127127
DefaultScheduledTask t = ref.get();

0 commit comments

Comments
 (0)