This is an automated email from the ASF dual-hosted git repository. ifesdjeen pushed a commit to branch cep-15-accord in repository https://gitbox.apache.org/repos/asf/cassandra.git
commit 4467abbe09bd4be16407e20238099cc18178511e Author: Alex Petrov <[email protected]> AuthorDate: Tue Oct 22 11:58:24 2024 +0200 Shut down scheduler with "now" --- .../org/apache/cassandra/service/accord/api/AccordScheduler.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/java/org/apache/cassandra/service/accord/api/AccordScheduler.java b/src/java/org/apache/cassandra/service/accord/api/AccordScheduler.java index a616cf05d4..50720952a4 100644 --- a/src/java/org/apache/cassandra/service/accord/api/AccordScheduler.java +++ b/src/java/org/apache/cassandra/service/accord/api/AccordScheduler.java @@ -86,7 +86,11 @@ public class AccordScheduler implements Scheduler, Shutdownable @Override public void shutdown() { - scheduledExecutor.shutdown(); + for (Runnable c : shutdownNow()) + { + if (c instanceof java.util.concurrent.Future<?>) + ((java.util.concurrent.Future<?>) c).cancel(false); + } } @Override --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
