remove EasyThread library

Author: yjfnypeu

app/build.gradle

@@ -28,11 +28,10 @@ dependencies {
     implementation 'com.android.support:appcompat-v7:27.1.1'
 
     implementation 'com.alibaba:fastjson:1.2.46'
-    implementation 'com.github.yjfnypeu:EasyThread:0.6.0'
 
     implementation "com.jakewharton:butterknife:$butterknife_version"
     kapt "com.jakewharton:butterknife-compiler:$butterknife_version"
 
     implementation project(':utils')
-//    implementation 'com.github.yjfnypeu:EasyAndroid:1.0.9'
+//    implementation 'com.github.yjfnypeu:EasyAndroid:1.1.0'
 }

app/src/main/java/com/haoge/sample/easyandroid/activities/EasyResultActivity.kt

@@ -4,6 +4,7 @@ import android.content.Intent
 import butterknife.OnClick
 import com.haoge.easyandroid.easy.EasyActivityResult
 import com.haoge.easyandroid.easy.EasyLog
+import com.haoge.easyandroid.easy.EasyToast
 import com.haoge.sample.easyandroid.BaseActivity
 import com.haoge.sample.easyandroid.R
 
@@ -20,23 +21,23 @@ class EasyResultActivity: BaseActivity() {
     fun normalStart() {
         EasyActivityResult.startActivity(this,
                 Intent(this, EasyToastActivity::class.java),
-                {_, _ -> EasyLog.DEFAULT.e("正常启动模式接收返回信息") })
+                {_, _ -> EasyToast.DEFAULT.show("正常启动模式接收返回信息") })
     }
 
     @OnClick(R.id.violentStart)
     fun violentStart() {
         // 暴击启动测试：同时被调用启动多次，应只有第一次启动成功
         EasyActivityResult.startActivity(this,
                 Intent(this, EasyToastActivity::class.java),
-                {_, _ -> EasyLog.DEFAULT.e("暴击启动测试：第一次启动任务 接收返回信息") })
+                {_, _ -> EasyToast.DEFAULT.show("暴击启动测试：第一次启动任务 接收返回信息") })
 
         EasyActivityResult.startActivity(this,
                 Intent(this, EasyToastActivity::class.java),
-                {_, _ -> EasyLog.DEFAULT.e("暴击启动测试：第二次启动任务 接收返回信息") })
+                {_, _ -> EasyToast.DEFAULT.show("暴击启动测试：第二次启动任务 接收返回信息") })
 
         EasyActivityResult.startActivity(this,
                 Intent(this, EasyToastActivity::class.java),
-                {_, _ -> EasyLog.DEFAULT.e("暴击启动测试：第三次启动任务 接收返回信息") })
+                {_, _ -> EasyToast.DEFAULT.show("暴击启动测试：第三次启动任务 接收返回信息") })
     }
 
     override fun onActivityResult(requestCode: Int, resultCode: Int, data: Intent?) {

app/src/main/java/com/haoge/sample/easyandroid/activities/mvp/MVPDemoActivity.kt

@@ -1,12 +1,12 @@
 package com.haoge.sample.easyandroid.activities.mvp
 
 import android.os.Bundle
+import com.haoge.easyandroid.easy.EasyExecutor
 import com.haoge.easyandroid.easy.EasyToast
 import com.haoge.easyandroid.mvp.MVPPresenter
 import com.haoge.easyandroid.mvp.MVPView
 import com.haoge.sample.easyandroid.R
-import com.lzh.easythread.AsyncCallback
-import com.lzh.easythread.EasyThread
+import java.util.concurrent.Callable
 
 /**
  * @author haoge on 2018/5/30
@@ -34,29 +34,27 @@ interface DemoView:MVPView {
 
 // P层数据处理：处理与界面无关的、与数据处理相关的逻辑。并用于连接M与V层的中间件
 class DemoPresenter(view:DemoView):MVPPresenter<DemoView>(view) {
-    val executor: EasyThread by lazy { EasyThread.Builder.createSingle().build() }
+    val executor: EasyExecutor by lazy { EasyExecutor.newBuilder(1)
+            .onError { _, _ ->
+                if (!isViewAttached()) return@onError
+                view.hideLoadingDialog()
+            }
+            .build() }
 
     fun requestData() {
         view?.showLoadingDialog()
 
         // 使用线程池模拟网络请求环境。
-        executor.async({
+        executor.async(Callable {
             Thread.sleep(3000)
-            return@async "Hello world"
-        }, object : AsyncCallback<String>{
-            override fun onSuccess(t: String?) {
-                // 对于异步网络操作，回调时尽量先判断一下是否处于View绑定状态。
-                if (!isViewAttached()) return
-
-                view?.hideLoadingDialog()
-                view?.onQuerySuccess(t)
-            }
-
-            override fun onFailed(t: Throwable?) {
-                view?.hideLoadingDialog()
-                view?.toastMessage("获取数据失败：Cause by -> ${t?.message?:"未知错误"}")
-            }
-        })
+            return@Callable "Hello world!"
+        }) {
+            // 对于异步网络操作，回调时尽量先判断一下是否处于View绑定状态。
+            if (!isViewAttached()) return@async
+
+            view?.hideLoadingDialog()
+            view?.onQuerySuccess(it)
+        }
     }
 
 }