updateCoe

Author: Faqiang Lv

README.md

@@ -2,6 +2,9 @@
 用于Android 日常代码测试，效果整理
 
 ### Update Log:
+ - 2018年08月27日
+
+    [Kotlin 协程+Channel 控制线程切换](https://github.com/lvfaqiang/AndroidTestCode/blob/master/app/src/main/java/com/lvfq/code/coroutines/thread_toggle/CoroutineToggleActivity.kt)
  - 2018年08月24日
 
     [Kotlin Channel](https://github.com/lvfaqiang/AndroidTestCode/blob/master/app/src/main/java/com/lvfq/code/coroutines/eventbus)

app/src/main/AndroidManifest.xml

@@ -19,7 +19,7 @@
         android:supportsRtl="true"
         android:theme="@style/AppTheme">
 
-        <activity android:name=".coroutines.eventbus.CoroutinesMainActivity">
+        <activity android:name=".coroutines.thread_toggle.CoroutineToggleActivity">
             <intent-filter>
                 <action android:name="android.intent.action.MAIN" />
 

app/src/main/java/com/lvfq/code/coroutines/thread_toggle/CoroutineJava.java

@@ -0,0 +1,85 @@
+package com.lvfq.code.coroutines.thread_toggle;
+
+import org.jetbrains.annotations.NotNull;
+
+import kotlin.Unit;
+import kotlin.coroutines.experimental.Continuation;
+import kotlin.coroutines.experimental.CoroutineContext;
+
+/**
+ * CoroutineJava
+ *
+ * @author FaQiang on 2018/8/27 上午9:57
+ * @Github: <a href="https://github.com/lvfaqiang"/>
+ * @Blog: <a href="http://blog.csdn.net/lv_fq"/>
+ * @desc :
+ */
+public class CoroutineJava {
+
+    public static void main(String[] args) {
+        test();
+        CoroutineUtils.start();
+        System.out.println("main Function");
+    }
+
+
+    public static void test() {
+        async(new Task() {
+            @Override
+            public void run() {
+                try {
+                    Thread.sleep(1000);
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+                int i = "string".hashCode();
+                ui(new UI() {
+                    @Override
+                    public void run() {
+                        System.out.println("------- UI - " + Thread.currentThread().getName());
+                    }
+                });
+            }
+        });
+    }
+
+    public static void async(Task task) {
+        CoroutineUtils.async(task, new Continuation<Unit>() {
+            @NotNull
+            @Override
+            public CoroutineContext getContext() {
+                return null;
+            }
+
+            @Override
+            public void resume(Unit unit) {
+
+            }
+
+            @Override
+            public void resumeWithException(Throwable throwable) {
+
+            }
+        });
+    }
+
+    public static void ui(UI task) {
+        CoroutineUtils.ui(task, new Continuation<Unit>() {
+            @NotNull
+            @Override
+            public CoroutineContext getContext() {
+                return null;
+            }
+
+            @Override
+            public void resume(Unit unit) {
+
+            }
+
+            @Override
+            public void resumeWithException(Throwable throwable) {
+
+            }
+        });
+    }
+}

app/src/main/java/com/lvfq/code/coroutines/thread_toggle/CoroutineToggleActivity.kt

@@ -0,0 +1,42 @@
+package com.lvfq.code.coroutines.thread_toggle
+
+import android.os.Bundle
+import android.support.v7.app.AppCompatActivity
+import android.view.View
+import com.lvfq.code.R
+import com.lvfq.library.utils.LvLog
+
+/**
+ * CoroutineToggleActivity
+ * @author FaQiang on 2018/8/27 上午10:18
+ * @Github: <a href="https://github.com/lvfaqiang"/>
+ * @Blog: <a href="http://blog.csdn.net/lv_fq"/>
+ * @desc :
+ *
+ */
+class CoroutineToggleActivity : AppCompatActivity() {
+
+    override fun onCreate(savedInstanceState: Bundle?) {
+        super.onCreate(savedInstanceState)
+        setContentView(R.layout.activity_coroutine_toggle)
+        start()
+        LvLog.i("lfq", "onCreate====================")
+    }
+
+    fun button1(v: View) {
+        CoroutineJava.async(object : Task() {
+            override fun run() {
+                Thread.sleep(1000)
+                LvLog.i("lfq", "task==========${Thread.currentThread().name}")
+            }
+        })
+    }
+
+    fun button2(v: View) {
+        CoroutineJava.ui(object : UI() {
+            override fun run() {
+                LvLog.i("lfq", "UI==========${Thread.currentThread().name}")
+            }
+        })
+    }
+}

app/src/main/java/com/lvfq/code/coroutines/thread_toggle/CoroutineUtils.kt

@@ -0,0 +1,57 @@
+@file:JvmName("CoroutineUtils")
+
+package com.lvfq.code.coroutines.thread_toggle
+
+import android.os.AsyncTask
+import kotlinx.coroutines.experimental.CoroutineDispatcher
+import kotlinx.coroutines.experimental.android.UI
+import kotlinx.coroutines.experimental.channels.Channel
+import kotlinx.coroutines.experimental.launch
+import kotlin.coroutines.experimental.CoroutineContext
+
+/**
+ * CoroutineUtils
+ * @author FaQiang on 2018/8/27 上午9:12
+ * @Github: <a href="https://github.com/lvfaqiang"/>
+ * @Blog: <a href="http://blog.csdn.net/lv_fq"/>
+ * @desc :
+ *
+ */
+val channel = Channel<Runnable>(2)
+
+abstract class Task : Runnable
+
+abstract class UI : Runnable
+
+suspend fun async(task: Task) {
+    channel.send(task)
+}
+
+suspend fun ui(task: UI) {
+    channel.send(task)
+}
+
+fun start() {
+    launch(AndroidCommonPool) {
+        while (true) {
+            val t = channel.receive()
+            when (t) {
+                is UI -> {
+                    launch(UI) {
+                        t.run()
+                    }
+                }
+                is Task -> {
+                    t.run()
+                }
+            }
+        }
+    }
+}
+
+object AndroidCommonPool : CoroutineDispatcher() {
+    override fun dispatch(context: CoroutineContext, block: Runnable) {
+        AsyncTask.THREAD_POOL_EXECUTOR.execute(block)
+    }
+
+}

app/src/main/res/layout/activity_coroutine_toggle.xml

@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="utf-8"?>
+<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
+    android:id="@+id/root_layout"
+    android:layout_width="match_parent"
+    android:layout_height="match_parent"
+    android:orientation="vertical">
+
+    <Button
+        android:id="@+id/button"
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:onClick="button1"
+        android:text="Async" />
+
+    <Button
+        android:id="@+id/button2"
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:onClick="button2"
+        android:text="UI" />
+</LinearLayout>