Merge branch 'master' of https://github.com/Justson/Queue

Author: Justson

.gitignore

@@ -11,7 +11,6 @@
 .mtj.tmp/
 
 # Package Files #
-*.jar
 *.war
 *.nar
 *.ear
@@ -35,4 +34,5 @@ hs_err_pid*
 /captures
 .externalNativeBuild
 .cxx
-package.json
+package.json
+node_modules

.idea/inspectionProfiles/Project_Default.xml

@@ -1 +1,85 @@
-# Queue
+# Dispatch-Queue
+
+### 拓展了Android OS MessageQueue
+
+
+## 引入
+
+* Gradle
+
+
+```gradle
+implementation 'com.github.Justson:dispatch-queue:v1.0.3'
+```
+
+
+## 特性
+
+* 线程可以配对交换元素在同步点
+* 线程空闲后执行task
+* 阻塞执行
+* 线程之间交叉执行
+
+
+## 控制线程执行顺序
+
+``` 
+        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 5"
+        });
+```
+
+```java
+ output the order :1, 2, 3, 4, 5 
+```
+
+
+
+## 创建 Dispatch Thread
+
+```
+        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
+        });
+```
+
+
+

.idea/misc.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,6 @@ 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')
+    implementation 'com.github.Justson:dispatch-queue:v1.0.3'
 }

README.md

@@ -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

@@ -3,13 +3,12 @@
 buildscript {
 
     repositories {
+        maven { url 'https://jitpack.io' }
         google()
         jcenter()
-        
     }
     dependencies {
-        classpath 'com.android.tools.build:gradle:3.6.1'
-        
+        classpath 'com.android.tools.build:gradle:3.6.3'
 
         // NOTE: Do not place your application dependencies here; they belong
         // in the individual module build.gradle files
@@ -18,9 +17,9 @@ buildscript {
 
 allprojects {
     repositories {
+        maven { url 'https://jitpack.io' }
         google()
         jcenter()
-        
     }
 }
 

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

@@ -1,4 +1,4 @@
-#Thu Jul 09 09:51:20 CST 2020
+#Sat Jul 11 22:33:09 CST 2020
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
 zipStoreBase=GRADLE_USER_HOME

build.gradle

@@ -194,13 +194,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()) {

gradle/wrapper/gradle-wrapper.properties

@@ -0,0 +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 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);
+    }
+}