package?io.mqttpush.mqttclient.conn;

import?java.util.concurrent.BlockingQueue;
import?java.util.concurrent.Future;
import?java.util.concurrent.linkedBlockingQueue;
import?java.util.concurrent.ScheduledThreadPoolExecutor;

/**
?*?取消執行的線程池
?*?@author?tianzhenjiu
?*
?*/
public?class?CancelbleExecutorService?extends?ScheduledThreadPoolExecutor{

	
	BlockingQueue>?futures=new?linkedBlockingQueue<>（1024）;
	public?CancelbleExecutorService（int?corePoolSize）?{
		super（corePoolSize）;
		
	}

	
	/**
	?*?刪除所有已有的任務
	?*/
	public?void?reset（）?{
		BlockingQueue?blockingQueue=super.getQueue（）;
		if（blockingQueue!=null）?{
			blockingQueue.forEach（（b）->{
				CancelbleExecutorService.this.remove（b）;
			}）;
		}
		
	}

	
}

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2019-01-09?09:12??mqtt-push\
?????文件?????????234??2019-01-09?09:12??mqtt-push\.gitignore
?????文件?????????864??2019-01-09?09:12??mqtt-push\README.md
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-admin\
?????文件?????????425??2019-01-09?09:12??mqtt-push\mqtt-admin\pom.xml
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\
?????文件?????????427??2019-01-09?09:12??mqtt-push\mqtt-commons\pom.xml
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\src\
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\conn\
?????文件?????????766??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\conn\CancelbleExecutorService.java
?????文件????????1457??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\conn\ConnectProperties.java
?????文件????????4440??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\conn\Connetor.java
?????文件?????????295??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\conn\Status.java
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\handle\
?????文件????????4707??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\handle\ConnectionHandle.java
?????文件????????2335??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\handle\PingRunnable.java
?????文件????????4040??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\handle\PubHandle.java
?????文件?????????944??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\handle\SubHandle.java
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\service\
?????文件?????????582??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\service\ApiService.java
?????文件????????5049??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\service\DefaultApiService.java
?????文件?????????446??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\service\DefaultMessageListener.java
?????文件?????????281??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttclient\service\MessageListener.java
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttserver\
?????目錄???????????0??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttserver\beans\
?????文件????????1488??2019-01-09?09:12??mqtt-push\mqtt-commons\src\main\java\io\mqttpush\mqttserver\beans\ConstantBean.java
............此處省略134個文件信息