force lingering threads to shutdown

manojdbos · manojdbos · commit 15466ecb4bee · 2025-07-25T16:53:30.000-07:00
diff --git a/src/main/java/dev/dbos/transact/execution/DBOSExecutor.java b/src/main/java/dev/dbos/transact/execution/DBOSExecutor.java
@@ -52,7 +52,7 @@ public void setQueueService(QueueService queueService) {
 
     public void shutdown() {
         workflowRegistry = null ;
-        executorService.shutdown();
+        executorService.shutdownNow();
         systemDatabase.destroy() ;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ public void setQueueService(QueueService queueService) {`
`52`	`52`
`53`	`53`	`public void shutdown() {`
`54`	`54`	`workflowRegistry = null ;`
`55`		`- executorService.shutdown();`
	`55`	`+ executorService.shutdownNow();`
`56`	`56`	`systemDatabase.destroy() ;`
`57`	`57`	`}`
`58`	`58`