From 9a71f0ac924615d21882e1faa4bbda0c2e5eb7d7 Mon Sep 17 00:00:00 2001
From: yao <yaoqiangpersonal@gamil.com>
Date: Tue, 15 Dec 2020 17:05:16 +0800
Subject: [PATCH] =?UTF-8?q?pageCount=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/us/codecraft/webmagic/Spider.java      | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/webmagic-core/src/main/java/us/codecraft/webmagic/Spider.java b/webmagic-core/src/main/java/us/codecraft/webmagic/Spider.java
index 62c989f..1a03bbf 100644
--- a/webmagic-core/src/main/java/us/codecraft/webmagic/Spider.java
+++ b/webmagic-core/src/main/java/us/codecraft/webmagic/Spider.java
@@ -24,6 +24,7 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicLong;
+import java.util.concurrent.atomic.LongAdder;
 import java.util.concurrent.locks.Condition;
 import java.util.concurrent.locks.ReentrantLock;
 
@@ -102,7 +103,7 @@ public class Spider implements Runnable, Task {
 
     private List<SpiderListener> spiderListeners;
 
-    private final AtomicLong pageCount = new AtomicLong(0);
+    private final LongAdder pageCount = new LongAdder();
 
     private Date startTime;
 
@@ -323,7 +324,7 @@ public class Spider implements Runnable, Task {
                             onError(request);
                             logger.error("process request " + request + " error", e);
                         } finally {
-                            pageCount.incrementAndGet();
+                            pageCount.increment();
                             signalNewUrl();
                         }
                     }
@@ -335,7 +336,7 @@ public class Spider implements Runnable, Task {
         if (destroyWhenExit) {
             close();
         }
-        logger.info("Spider {} closed! {} pages downloaded.", getUUID(), pageCount.get());
+        logger.info("Spider {} closed! {} pages downloaded.", getUUID(), pageCount.sumThenReset());
     }
 
     protected void onError(Request request) {
@@ -645,7 +646,7 @@ public class Spider implements Runnable, Task {
      * @since 0.4.1
      */
     public long getPageCount() {
-        return pageCount.get();
+        return pageCount.sum();
     }
 
     /**