一、前言
总的来说,Android的线程间通信主要有以下几种方式:
1.系统自带(原生):Handler机制;AsyncTask;管道流通信;共享内存;java里的wait(),notify(),notifyAll();Activity的runOnUiThread(Runnable action)
及View的post(Runnable action)
等;
2.第三方开源框架:EventBus等。
归根结底,AsyncTask,runOnUiThread(Runnable action)及post(Runnable action)甚至EventBus最终使用的还是Handler机制来进行线程间的通信。所以,线程间的通信实际上有这几种:Handler机制;管道流通信;共享内存;java里的wait(),notify(),notifyAll()(需要在同步语句块里面才能使用)。
二、各种通信方式解析:
1.Handler机制是Android中最常用的机制,通常用于子线程来执行耗时任务完毕后,通过调用主线程的handler来发送信息,这样就可以在主线程的handler的handleMessage中回调,我们这时就处于主线程中,可以对UI进行更新等操作。
2.管道流通信:
package com.wei.wanandroid.javasources.thread;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.PipedReader;
import java.io.PipedWriter;
/**
* 通常没有必要使用管道流来控制两个线程之间的通信,因为两个线程属于同一个进程,它们可以非常
* 方便地共享数据,这种方式才是线程之间进行信息交换的最好方式,而不是使用管道流。
* @author: WEI
* @date: 2018/7/24
*/
public class PipedCommunicationTest
{
public static void main(String[] args) {
PipedWriter pipedWriter = null;
PipedReader pipedReader = null;
try {
// 分别创建两个独立的管道输出流、输入流
pipedWriter = new PipedWriter();
pipedReader = new PipedReader();
// 连接管道输出流、输入流
pipedWriter.connect(pipedReader);
// 将连接好的管道流分别传入两个线程,就可以让两个线程通过管道流进行通信
new WriterThread(pipedWriter).start();
new ReaderThread(pipedReader).start();
}catch (Exception e)
{
e.printStackTrace();
}
}
}
class ReaderThread extends Thread
{
private PipedReader mPipedReader;
// 用于包装管道流的 BufferedReader 对象
private BufferedReader mBufferedReader;
public ReaderThread(PipedReader pipedReader)
{
mPipedReader = pipedReader;
mBufferedReader = new BufferedReader(mPipedReader);
}
@Override
public void run() {
String buf;
try {
// 逐行读取管道输入流中的内容
while ((buf = mBufferedReader.readLine()) != null)
{
System.out.println(buf);
}
}catch (Exception e)
{
e.printStackTrace();
}finally {
try {
if (mBufferedReader != null)
{
mBufferedReader.close();
}
}catch (Exception e)
{
e.printStackTrace();
}
}
}
}
class WriterThread extends Thread
{
String[] books = {"Android开发艺术探索", "Android核心分析",
"Android权威指南", "Android高级进阶"};
private PipedWriter mPipedWriter;
public WriterThread(PipedWriter pipedWriter)
{
mPipedWriter = pipedWriter;
}
@Override
public void run() {
try {
// 循环100次,向管道输出流中写入100组字符串
for (int i = 0; i < 100; i ++)
{
mPipedWriter.write(books[i % 4] + "\n");
}
}catch (Exception e)
{
e.printStackTrace();
}finally {
try {
if (mPipedWriter != null)
{
mPipedWriter.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}