feat(dispatch): provide dispatch thread to create new thread

Author: Justson

.idea/gradle.xml

@@ -20,6 +20,10 @@ android {
             proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
         }
     }
+    compileOptions {
+        sourceCompatibility = 1.8
+        targetCompatibility = 1.8
+    }
 
 }
 
@@ -31,4 +35,5 @@ dependencies {
     testImplementation 'junit:junit:4.12'
     androidTestImplementation 'androidx.test.ext:junit:1.1.1'
     androidTestImplementation 'androidx.test.espresso:espresso-core:3.2.0'
+    implementation project(path: ':library')
 }

.idea/misc.xml

@@ -2,6 +2,9 @@
 
 import android.os.Bundle;
 
+import com.queue.library.Dispatch;
+import com.queue.library.DispatchThread;
+
 import androidx.appcompat.app.AppCompatActivity;
 
 public class MainActivity extends AppCompatActivity {
@@ -10,5 +13,75 @@ public class MainActivity extends AppCompatActivity {
     protected void onCreate(Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
         setContentView(R.layout.activity_main);
+
+
+//        /**
+//         * use a
+//         */
+//        final StringBuffer output = new StringBuffer();
+//        AsyncTask.execute(() -> {
+//            output.append(1).append("-").append(Thread.currentThread().getName()).append(", ");
+//            GlobalQueue.getMainQueue().postRunnableBlocking(() -> {
+//                // do you work , in the main-Thread
+//                output.append(2).append("-").append(Thread.currentThread().getName()).append(", ");
+//
+//            });
+//            output.append(3).append("-").append(Thread.currentThread().getName()).append(", ");
+//
+//            // invoke in the main-Thread and return a string data
+//            String message = GlobalQueue.getMainQueue().call(() -> {
+//                output.append(4).append("-").append(Thread.currentThread().getName()).append(", ");
+//                return "hello world";
+//            });
+//            output.append(5).append("-").append(Thread.currentThread().getName()).append(" data ").append(message);
+//            System.out.println(output.toString());
+//            // output  the order "1 2 3 4"
+//        });
+
+//        final StringBuffer output = new StringBuffer();
+//        AsyncTask.execute(() -> {
+//            output.append(1).append(", ");
+//            GlobalQueue.getMainQueue().postRunnableBlocking(() -> {
+//                // do you work , in the main-Thread
+//                output.append(2).append(", ");
+//
+//            });
+//            output.append(3).append(", ");
+//
+//            // invoke in the main-Thread and return a string data
+//            String message = GlobalQueue.getMainQueue().call(() -> {
+//                output.append(4).append(", ");
+//                return "hello world";
+//            });
+//            output.append(5).append(" data ").append(message);
+//            System.out.println(output.toString());
+//            // output  the order "1 2 3 4"
+//        });
+
+        /**
+         * use b
+         */
+        Dispatch messageDispatch = DispatchThread.create("message");
+
+        messageDispatch.postRunnable(() -> {
+            // do you work , work in message thread
+        });
+
+        System.out.println("1");
+        messageDispatch.postRunnableScissors(() -> {
+            System.out.println("2");
+        });
+        System.out.println("3");
+        // output 1 2 3
+
+        // from message thread get a number, it will blocking until working finish.
+        int i = messageDispatch.call(() -> 1);
+
+
+        messageDispatch.postRunnableInIdleRunning(() -> {
+            // do your work , when the message thread idle will callback this runable
+        });
     }
+
+
 }

app/build.gradle

@@ -193,13 +193,6 @@ public void postRunnableImmediately(Runnable runnable) {
         postAtFont(runnable);
     }
 
-    public void postRunnableQuick(Runnable runnable) {
-        if (Looper.myLooper() == getLooper()) {
-            runnable.run();
-            return;
-        }
-        postRunnable(runnable);
-    }
 
     public void post(Runnable runnable) {
         if (Looper.myLooper() == getLooper()) {

app/src/main/java/com/queue/sample/MainActivity.java

@@ -1,9 +1,24 @@
 package com.queue.library;
 
+import android.os.HandlerThread;
+import android.os.Looper;
+import android.os.Process;
+
 /**
  * @author cenxiaozhong
  * @date 2020/7/11
  * @since 1.0.0
  */
-public class DispatchThread {
+public final class DispatchThread {
+
+    public static Dispatch create(String name) {
+        return create(name, Process.THREAD_PRIORITY_DEFAULT);
+    }
+
+    public static Dispatch create(String name, int priority) {
+        HandlerThread handlerThread = new HandlerThread(name, priority);
+        handlerThread.start();
+        Looper looper = handlerThread.getLooper();
+        return new Dispatch(looper);
+    }
 }