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

liujun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git


The following commit(s) were added to refs/heads/master by this push:
     new faf3983  Merge pull request #3323, fix double-checked locking.
faf3983 is described below

commit faf398371059c02edcd4e83998cc0fc73935114a
Author: Yuhao Bi <[email protected]>
AuthorDate: Thu Jan 24 14:48:24 2019 +0800

    Merge pull request #3323, fix double-checked locking.
---
 .../org/apache/dubbo/metadata/integration/MetadataReportService.java    | 2 +-
 .../java/org/apache/dubbo/metadata/support/AbstractMetadataReport.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/integration/MetadataReportService.java
 
b/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/integration/MetadataReportService.java
index d0dfa73..c457950 100644
--- 
a/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/integration/MetadataReportService.java
+++ 
b/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/integration/MetadataReportService.java
@@ -38,7 +38,7 @@ public class MetadataReportService {
 
     protected final Logger logger = LoggerFactory.getLogger(getClass());
 
-    private static MetadataReportService metadataReportService;
+    private static volatile MetadataReportService metadataReportService;
     private static Object lock = new Object();
 
     private MetadataReportFactory metadataReportFactory = 
ExtensionLoader.getExtensionLoader(MetadataReportFactory.class).getAdaptiveExtension();
diff --git 
a/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/support/AbstractMetadataReport.java
 
b/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/support/AbstractMetadataReport.java
index bedb085..f1bff8a 100644
--- 
a/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/support/AbstractMetadataReport.java
+++ 
b/dubbo-metadata-report/dubbo-metadata-report-api/src/main/java/org/apache/dubbo/metadata/support/AbstractMetadataReport.java
@@ -357,7 +357,7 @@ public abstract class AbstractMetadataReport implements 
MetadataReport {
         protected final Logger logger = LoggerFactory.getLogger(getClass());
 
         final ScheduledExecutorService retryExecutor = 
Executors.newScheduledThreadPool(0, new 
NamedThreadFactory("DubboRegistryFailedRetryTimer", true));
-        ScheduledFuture retryScheduledFuture;
+        volatile ScheduledFuture retryScheduledFuture;
         AtomicInteger retryCounter = new AtomicInteger(0);
         // retry task schedule period
         long retryPeriod;

Reply via email to