File tree Expand file tree Collapse file tree 1 file changed +15
-12
lines changed
shedlock-core/src/main/java/net/javacrumbs/shedlock/core Expand file tree Collapse file tree 1 file changed +15
-12
lines changed Original file line number Diff line number Diff line change @@ -44,19 +44,22 @@ public void executeIfNotLocked(Runnable task) {
44
44
logger .debug ("No lock configuration for {}. Executing without lock." , task );
45
45
task .run ();
46
46
} else {
47
- LockConfiguration lockConfig = lockConfigOptional .get ();
48
- Optional <SimpleLock > lock = lockProvider .lock (lockConfig );
49
- if (lock .isPresent ()) {
50
- try {
51
- logger .debug ("Locked {}." , lockConfig .getName ());
52
- task .run ();
53
- } finally {
54
- lock .get ().unlock ();
55
- logger .debug ("Unlocked {}." , lockConfig .getName ());
56
- }
57
- } else {
58
- logger .info ("Not executing {}. It's locked." , lockConfig .getName ());
47
+ executeIfNotLocked (task , lockConfigOptional .get ());
48
+ }
49
+ }
50
+
51
+ private void executeIfNotLocked (Runnable task , LockConfiguration lockConfig ) {
52
+ Optional <SimpleLock > lock = lockProvider .lock (lockConfig );
53
+ if (lock .isPresent ()) {
54
+ try {
55
+ logger .debug ("Locked {}." , lockConfig .getName ());
56
+ task .run ();
57
+ } finally {
58
+ lock .get ().unlock ();
59
+ logger .debug ("Unlocked {}." , lockConfig .getName ());
59
60
}
61
+ } else {
62
+ logger .info ("Not executing {}. It's locked." , lockConfig .getName ());
60
63
}
61
64
}
62
65
}
You can’t perform that action at this time.
0 commit comments