Update to temporal-sdk 1.27.0 and add support for vthreads

Signed-off-by: Greg Haskins <[email protected]>

Author: ghaskins

project.clj

@@ -12,11 +12,11 @@
             [jonase/eastwood "1.3.0"]
             [lein-codox "0.10.8"]]
   :dependencies [[org.clojure/clojure "1.11.4"]
-                 [org.clojure/core.async "1.6.681"]
-                 [io.temporal/temporal-sdk "1.25.1"]
-                 [io.temporal/temporal-testing "1.25.1"]
-                 [com.taoensso/encore "3.117.0"]
-                 [com.taoensso/timbre "6.5.0"]
+                 [org.clojure/core.async "1.7.701"]
+                 [io.temporal/temporal-sdk "1.27.0"]
+                 [io.temporal/temporal-testing "1.27.0"]
+                 [com.taoensso/encore "3.133.0"]
+                 [com.taoensso/timbre "6.6.1"]
                  [com.taoensso/nippy "3.4.2"]
                  [funcool/promesa "9.2.542"]
                  [medley "1.4.0"]
@@ -31,7 +31,7 @@
   :profiles {:dev {:dependencies   [[org.clojure/tools.namespace "1.5.0"]
                                     [eftest "0.6.0"]
                                     [mockery "0.1.4"]
-                                    [io.temporal/temporal-opentracing "1.25.1"]]
+                                    [io.temporal/temporal-opentracing "1.27.0"]]
                    :resource-paths ["test/temporal/test/resources"]}}
   :cloverage {:runner :eftest
               :runner-opts {:multithread? false

src/temporal/client/worker.clj

@@ -38,12 +38,14 @@ Options for configuring the worker-factory (See [[start]])
 | :max-workflow-thread-count                     | Maximum number of threads available for workflow execution across all workers created by the Factory. | int | 600 |
 | :worker-interceptors                           | Collection of WorkerInterceptors                                   | [WorkerInterceptor](https://javadoc.io/doc/io.temporal/temporal-sdk/latest/io/temporal/common/interceptors/WorkerInterceptor.html) | |
 | :workflow-cache-size                           | To avoid constant replay of code the workflow objects are cached on a worker. This cache is shared by all workers created by the Factory. | int | 600 |
+| :using-virtual-workflow-threads                | Use Virtual Threads for all workflow threads across all workers created by this factory. This option is only supported for JDK >= 21. If set then :max-workflow-thread-count is ignored. | boolean | false       |
 "
 
   {:enable-logging-in-replay             #(.setEnableLoggingInReplay ^WorkerFactoryOptions$Builder %1 %2)
    :max-workflow-thread-count            #(.setMaxWorkflowThreadCount ^WorkerFactoryOptions$Builder %1 %2)
    :worker-interceptors                  #(.setWorkerInterceptors ^WorkerFactoryOptions$Builder %1 (into-array WorkerInterceptor %2))
-   :workflow-cache-size                  #(.setWorkflowCacheSize ^WorkerFactoryOptions$Builder %1 %2)})
+   :workflow-cache-size                  #(.setWorkflowCacheSize ^WorkerFactoryOptions$Builder %1 %2)
+   :using-virtual-workflow-threads       #(.setUsingVirtualWorkflowThreads ^WorkerFactoryOptions$Builder %1 %2)})
 
 (defn ^:no-doc worker-factory-options->
   ^WorkerFactoryOptions [params]

test/temporal/test/vthreads.clj

@@ -0,0 +1,38 @@
+;; Copyright © Manetu, Inc.  All rights reserved
+
+(ns temporal.test.vthreads
+  (:require [clojure.test :refer :all]
+            [taoensso.timbre :as log]
+            [promesa.core :as p]
+            [promesa.exec :refer [vthreads-supported?]]
+            [temporal.client.core :as c]
+            [temporal.testing.env :as e]
+            [temporal.workflow :refer [defworkflow]])
+  (:import [java.time Duration]))
+
+(def task-queue ::default)
+
+(defworkflow vthread-workflow
+  [args]
+  (-> (Thread/currentThread)
+      (.isVirtual)))
+
+(defn execute [opts]
+  (let [env      (e/create opts)
+        client   (e/get-client env)
+        _        (e/start env {:task-queue task-queue})
+        workflow (c/create-workflow client vthread-workflow {:task-queue task-queue :workflow-execution-timeout (Duration/ofSeconds 1) :retry-options {:maximum-attempts 1}})]
+    (c/start workflow {})
+    @(-> (c/get-result workflow)
+         (p/finally (fn [_ _]
+                      (e/stop env))))))
+
+(deftest the-test
+  (testing "Verifies that we do not use vthreads by default"
+    (is (false? (execute {}))))
+  (testing "Verifies that we do not use vthreads if we specifically disable them"
+    (is (false? (execute {:worker-factory-options {:using-virtual-workflow-threads false}}))))
+  (testing "Verifies that we can enable vthread support"
+    (if vthreads-supported?
+      (is (true? (execute {:worker-factory-options {:using-virtual-workflow-threads true}})))
+      (log/info "vthreads require JDK >= 21, skipping test"))))