fix bug

pom.xml

@@ -6,7 +6,7 @@
         <version>7</version>
     </parent>
     <groupId>us.codecraft.duiba</groupId>
-    <version>0.7.8-sjl-SNAPSHOT</version>
+    <version>0.7.9-102-SNAPSHOT</version>
     <modelVersion>4.0.0</modelVersion>
     <packaging>pom</packaging>
     <properties>

webmagic-core/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>us.codecraft.duiba</groupId>
         <artifactId>webmagic-parent</artifactId>
-        <version>0.7.8-sjl-SNAPSHOT</version>
+        <version>0.7.9-102-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

webmagic-core/src/main/java/us/codecraft/webmagic/Spider.java

@@ -305,6 +305,7 @@ public class Spider implements Runnable, Task {
         initComponent();
         logger.info("Spider {} started!",getUUID());
         while (!Thread.currentThread().isInterrupted() && stat.get() == STAT_RUNNING) {
+        //while (!Thread.interrupted() && stat.get() == STAT_RUNNING) {
             final Request request = scheduler.poll(this);
             if (request == null) {
                 if (threadPool.getThreadAlive() == 0 && exitWhenComplete) {
@@ -453,6 +454,7 @@ public class Spider implements Runnable, Task {
             Thread.sleep(time);
         } catch (InterruptedException e) {
             logger.error("Thread interrupted when sleep",e);
+            Thread.currentThread().interrupt();
         }
     }
 
@@ -559,6 +561,7 @@ public class Spider implements Runnable, Task {
             newUrlCondition.await(emptySleepTime, TimeUnit.MILLISECONDS);
         } catch (InterruptedException e) {
             logger.warn("waitNewUrl - interrupted, error {}", e);
+            Thread.currentThread().interrupt();
         } finally {
             newUrlLock.unlock();
         }

webmagic-core/src/main/java/us/codecraft/webmagic/thread/CountableThreadPool.java

@@ -60,6 +60,7 @@ public class CountableThreadPool {
                     try {
                         condition.await();
                     } catch (InterruptedException e) {
+                        Thread.currentThread().interrupt();
                     }
                 }
             } finally {

webmagic-extension/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>us.codecraft.duiba</groupId>
         <artifactId>webmagic-parent</artifactId>
-        <version>0.7.8-sjl-SNAPSHOT</version>
+        <version>0.7.9-102-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

webmagic-samples/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>us.codecraft.duiba</groupId>
         <artifactId>webmagic-parent</artifactId>
-        <version>0.7.8-sjl-SNAPSHOT</version>
+        <version>0.7.9-102-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

webmagic-samples/src/main/java/us/codecraft/webmagic/samples/AnjukeSpider.java

@@ -86,7 +86,9 @@ public class AnjukeSpider implements PageProcessor {
                 .addUrl("https://www.anjuke.com/sy-city.html")
 //                .addUrl("https://lvliang.anjuke.com/community/p1/")
                 .thread(2).addPipeline(new ConsolePipeline());
-        anjuke.start();
+        anjuke.run();
+
+        Thread.currentThread().interrupt();
     }
 
 }

webmagic-saxon/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>us.codecraft.duiba</groupId>
         <artifactId>webmagic-parent</artifactId>
-        <version>0.7.8-sjl-SNAPSHOT</version>
+        <version>0.7.9-102-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

webmagic-scripts/pom.xml

@@ -3,7 +3,7 @@
     <parent>
         <groupId>us.codecraft.duiba</groupId>
         <artifactId>webmagic-parent</artifactId>
-        <version>0.7.8-sjl-SNAPSHOT</version>
+        <version>0.7.9-102-SNAPSHOT</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>