关于电梯调度的多线程demo初步以及上次的一些修改

Somersames · Somersames · commit f15677f98511 · 2017-05-10T22:53:09.000+08:00
diff --git a/src/main/java/Thread/Bank/QueuingNum1.java b/src/main/java/Thread/Bank/QueuingNum1.java
@@ -2,9 +2,7 @@
 
 import Thread.Bank.system.DoCall;
 
-import javax.print.Doc;
-import java.util.ArrayList;
-import java.util.List;
+
 
 /**
  * Created by szh on 2017/5/8.
diff --git a/src/main/java/Thread/Bank/system/BankSystem.java b/src/main/java/Thread/Bank/system/BankSystem.java
@@ -13,7 +13,7 @@ public void doSpend() {
         if (Store.queue.isEmpty()) {
             executor.shutdownNow();
         } else {
-            executor.execute(new PopWindows()); // 执行操作任务
+            executor.execute(new ServiceWindows(Store.queue.poll())); // 执行操作任务
         }
     }
 }
diff --git a/src/main/java/Thread/Bank/system/InitBank.java b/src/main/java/Thread/Bank/system/InitBank.java
@@ -30,17 +30,21 @@ private void init(){
         while (!Store.queue.isEmpty()){
 //            System.out.println("队列是否为空+！"+!Store.queue.isEmpty());
 //            bankSystem.doSpend();
-            this.executorService.execute(new PopWindows());
+            this.executorService.execute(new ServiceWindows(Store.queue.poll()));
         }
 //        System.out.println("已经执行到这里了");
 
     }
     public static void main(String args[]) throws InterruptedException {
         InitBank initBank =new InitBank();
         initBank.init();
-        Thread.sleep(1000);
-        if (Store.queue.isEmpty())
-        initBank.executorService.shutdownNow();
-
+        Thread.currentThread().sleep(20000);// 需要设置长时间，否则导致main方法结束后的下面方法结束了线程池
+//        if (Store.queue.isEmpty()) {
+//            try {
+//                initBank.executorService.shutdownNow();
+//            } catch (java.lang.NullPointerException e) {
+//                System.out.println("一经被捕捉");
+//            }
+//        }
     }
 }
diff --git a/src/main/java/Thread/Bank/system/PopWindows.java b/src/main/java/Thread/Bank/system/PopWindows.java
@@ -17,8 +17,12 @@ public void run() {
     }
 
     public void spend() throws InterruptedException {
-        int nowNUm =Store.queue.poll();
-        System.out.println("线程：" + Thread.currentThread().getName() + "正在为" + nowNUm + "服务");
-        Thread.currentThread().sleep(1000);
+        if(!Store.queue.isEmpty()) {
+            int nowNUm = Store.queue.poll();
+            System.out.println("线程：" + Thread.currentThread().getName() + "正在为" + nowNUm + "服务");
+            Thread.currentThread().sleep(1000);
+        }else{
+            System.out.println("当前一经没有客户");
+        }
     }
 }
diff --git a/src/main/java/Thread/elevator/EevatorControll.java b/src/main/java/Thread/elevator/EevatorControll.java
@@ -0,0 +1,8 @@
+package Thread.elevator;
+
+/**
+ * Created by szh on 2017/5/10.
+ */
+public class EevatorControll {
+
+}
diff --git a/src/main/java/Thread/elevator/Elevator.java b/src/main/java/Thread/elevator/Elevator.java
@@ -0,0 +1,33 @@
+package Thread.elevator;
+
+/**
+ * Created by szh on 2017/5/10.
+ */
+public class Elevator {
+    private int NowNum;
+
+    public Elevator() {
+    }
+
+    public int getNowNum() {
+        return NowNum;
+    }
+
+    public void setNowNum(int nowNum) {
+        NowNum = nowNum;
+    }
+    public void elevatorUp(){
+        if(this.NowNum == 10){
+            System.out.println("已经到达最高层");
+            return;
+        }
+        this.NowNum=this.NowNum +1;
+    }
+    public void elevatorDown(){
+        if(this.NowNum == 0){
+            System.out.println("已到达最底层");
+            return;
+        }
+        this.NowNum=this.NowNum - 1;
+    }
+}
diff --git a/src/main/java/Thread/elevator/ElevatorTest.java b/src/main/java/Thread/elevator/ElevatorTest.java
@@ -0,0 +1,13 @@
+package Thread.elevator;
+
+/**
+ * Created by szh on 2017/5/10.
+ */
+public class ElevatorTest {
+    public static void main(String args[]){
+        Elevator elevator =new Elevator();
+        elevator.setNowNum(10);
+        elevator.elevatorDown();
+        System.out.println(elevator.getNowNum());
+    }
+}

Original file line number	Diff line number	Diff line change
`@@ -13,7 +13,7 @@ public void doSpend() {`
`13`	`13`	`if (Store.queue.isEmpty()) {`
`14`	`14`	`executor.shutdownNow();`
`15`	`15`	`} else {`
`16`		`- executor.execute(new PopWindows()); // 执行操作任务`
	`16`	`+ executor.execute(new ServiceWindows(Store.queue.poll())); // 执行操作任务`
`17`	`17`	`}`
`18`	`18`	`}`
`19`	`19`	`}`
Original file line number	Diff line number	Diff line change
`@@ -17,8 +17,12 @@ public void run() {`
`17`	`17`	`}`
`18`	`18`
`19`	`19`	`public void spend() throws InterruptedException {`
`20`		`- int nowNUm =Store.queue.poll();`
`21`		`- System.out.println("线程：" + Thread.currentThread().getName() + "正在为" + nowNUm + "服务");`
`22`		`- Thread.currentThread().sleep(1000);`
	`20`	`+ if(!Store.queue.isEmpty()) {`
	`21`	`+ int nowNUm = Store.queue.poll();`
	`22`	`+ System.out.println("线程：" + Thread.currentThread().getName() + "正在为" + nowNUm + "服务");`
	`23`	`+ Thread.currentThread().sleep(1000);`
	`24`	`+ }else{`
	`25`	`+ System.out.println("当前一经没有客户");`
	`26`	`+ }`
`23`	`27`	`}`
`24`	`28`	`}`