Skip to content

Stabilize Worker virtual thread support #2947

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
maciejdudko merged 1 commit into from
Jul 13, 2026
+0 −11
Merged

Stabilize Worker virtual thread support #2947

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 0 additions & 2 deletions temporal-sdk/src/main/java/io/temporal/worker/WorkerFactoryOptions.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,6 @@ public Builder setEnableLoggingInReplay(boolean enableLoggingInReplay) {
*
* <p>Default is false
*/
@Experimental
public Builder setUsingVirtualWorkflowThreads(boolean usingVirtualWorkflowThreads) {
this.usingVirtualWorkflowThreads = usingVirtualWorkflowThreads;
return this;
Expand Down Expand Up @@ -307,7 +306,6 @@ public boolean isEnableLoggingInReplay() {
return enableLoggingInReplay;
}

@Experimental
public boolean isUsingVirtualWorkflowThreads() {
return usingVirtualWorkflowThreads;
}
Expand Down
9 changes: 0 additions & 9 deletions temporal-sdk/src/main/java/io/temporal/worker/WorkerOptions.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -437,7 +437,6 @@ public Builder setWorkerTuner(WorkerTuner workerTuner) {
* supported for JDK >= 21. Individual options for different types of workers can be set using
* the respective methods.
*/
@Experimental
public Builder setUsingVirtualThreads(boolean enable) {
this.usingVirtualThreadsOnWorkflowWorker = enable;
this.usingVirtualThreadsOnLocalActivityWorker = enable;
Expand All @@ -450,7 +449,6 @@ public Builder setUsingVirtualThreads(boolean enable) {
* Use Virtual Threads for the Workflow task executors created by this worker. This option is
* only supported for JDK >= 21.
*/
@Experimental
public Builder setUsingVirtualThreadsOnWorkflowWorker(boolean enable) {
this.usingVirtualThreadsOnWorkflowWorker = enable;
return this;
Expand All @@ -460,7 +458,6 @@ public Builder setUsingVirtualThreadsOnWorkflowWorker(boolean enable) {
* Use Virtual Threads for the Local Activity task executors created by this worker. This option
* is only supported for JDK >= 21.
*/
@Experimental
public Builder setUsingVirtualThreadsOnLocalActivityWorker(boolean enable) {
this.usingVirtualThreadsOnLocalActivityWorker = enable;
return this;
Expand All @@ -470,7 +467,6 @@ public Builder setUsingVirtualThreadsOnLocalActivityWorker(boolean enable) {
* Use Virtual Threads for the Activity task executors created by this worker. This option is
* only supported for JDK >= 21.
*/
@Experimental
public Builder setUsingVirtualThreadsOnActivityWorker(boolean enable) {
this.usingVirtualThreadsOnActivityWorker = enable;
return this;
Expand All @@ -480,7 +476,6 @@ public Builder setUsingVirtualThreadsOnActivityWorker(boolean enable) {
* Use Virtual Threads for the Nexus task executors created by this worker. This option is only
* supported for JDK >= 21.
*/
@Experimental
public Builder setUsingVirtualThreadsOnNexusWorker(boolean enable) {
this.usingVirtualThreadsOnNexusWorker = enable;
return this;
Expand Down Expand Up @@ -924,22 +919,18 @@ public String getIdentity() {
return identity;
}

@Experimental
public boolean isUsingVirtualThreadsOnWorkflowWorker() {
return usingVirtualThreadsOnActivityWorker;
}

@Experimental
public boolean isUsingVirtualThreadsOnActivityWorker() {
return usingVirtualThreadsOnActivityWorker;
}

@Experimental
public boolean isUsingVirtualThreadsOnLocalActivityWorker() {
return usingVirtualThreadsOnLocalActivityWorker;
}

@Experimental
public boolean isUsingVirtualThreadsOnNexusWorker() {
return usingVirtualThreadsOnNexusWorker;
}
Expand Down
Loading