(dubbo) branch 3.3 updated: Fix concurrency problem. (#15210)

[earthchen]

This is an automated email from the ASF dual-hosted git repository.

earthchen pushed a commit to branch 3.3
in repository https://gitbox.apache.org/repos/asf/dubbo.git


The following commit(s) were added to refs/heads/3.3 by this push:
     new 3e5216f0e9 Fix concurrency problem. (#15210)
3e5216f0e9 is described below

commit 3e5216f0e96edc3b92d7e681a61c020072be6dc8
Author: TomlongTK <longqian...@maoyan.com>
AuthorDate: Thu Mar 6 21:15:22 2025 +0800

    Fix concurrency problem. (#15210)
---
 .../java/org/apache/dubbo/common/threadpool/ThreadlessExecutor.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/dubbo-common/src/main/java/org/apache/dubbo/common/threadpool/ThreadlessExecutor.java
 
b/dubbo-common/src/main/java/org/apache/dubbo/common/threadpool/ThreadlessExecutor.java
index 85e590ae4a..181db9b404 100644
--- 
a/dubbo-common/src/main/java/org/apache/dubbo/common/threadpool/ThreadlessExecutor.java
+++ 
b/dubbo-common/src/main/java/org/apache/dubbo/common/threadpool/ThreadlessExecutor.java
@@ -95,8 +95,9 @@ public class ThreadlessExecutor extends 
AbstractExecutorService {
     public void execute(Runnable runnable) {
         RunnableWrapper run = new RunnableWrapper(runnable);
         queue.add(run);
-        if (waiter.get() != SHUTDOWN) {
-            LockSupport.unpark((Thread) waiter.get());
+        Object waiter = this.waiter.get();
+        if (waiter != SHUTDOWN) {
+            LockSupport.unpark((Thread) waiter);
         } else if (queue.remove(run)) {
             throw new RejectedExecutionException();
         }