传统多线程开发

Android开发高级进阶

第一章学习


传统多线程开发####

概要:

之前的文章里写过了AsyncTask的一些坑,这次就不讲它了,使用传统的 Handler和Message来进行线程的使用,并且第一次添加了CallBack方式的接口进行回调操作


多线程
这概念并不需要多余的介绍了,用法跟Java里没什么不同

new Thread(new Runnable() {
@Override
    public void run() {
    // 处理具体的逻辑
    }
}).start();

什么是UI线程,什么是工作线程:
Android中,将其他线程和主线程(UI线程)进行了区分,由于Android的图形界面总是伴随着各种动画效果,所以Android特地为UI自动开启了主线程,用于持续不断的计算,且UI的操作必须在主线程里进行,如果在主线程里进行了耗时操作,那就会出现ANR (Application Not Responding),此时,多线程就非常必要了。


从子线程回调数据进行操作:

简单的线程操作,只能控制他start,一旦运行完毕了,无法进行返回,或者无法进行UI的操,接下来为解决这两种问题,提供一些方法。

标准的线程间通讯是使用Handler+Message进行通讯的,当然这种通讯毕竟能够传递的参数非常有限,大致上只有int和object,非常少,某些时候用得并不顺手。



比如网络连接的时候,想要在联网获得Json文件后,立即调用另一个方法对此Json文件进行处理,此时可以引入回调的机制。

1.定义接口,是一个抽象方法

    public interface HttpCallbackListener {
        void onFinish(String response);
        void onError(Exception e);
    }

2.在联网方法的传入参数中,定义此接口

public static void sendHttpRequest(final String address, final HttpCallbackListener
            listener) {
        new Thread(new Runnable() {
            @Override
            public void run() {
                HttpURLConnection connection = null;
                try {
                    URL url = new URL(address);
                    connection = (HttpURLConnection) url.openConnection();
                    connection.setRequestMethod("GET");
                    connection.setConnectTimeout(8000);
                    connection.setReadTimeout(8000);
                    connection.setDoInput(true);
                    connection.setDoOutput(true);
                    InputStream in = connection.getInputStream();
                    BufferedReader reader = new BufferedReader(new
                            InputStreamReader(in));
                    StringBuilder response = new StringBuilder();
                    String line;
                    while ((line = reader.readLine()) != null) {
                        response.append(line);
                    }
                    if (listener != null) {
// 回调onFinish()方法
                        listener.onFinish(response.toString());
                    }
                } catch (Exception e) {
                    if (listener != null) {
// 回调onError()方法
                        listener.onError(e);
                    }
                } finally {
                    if (connection != null) {
                        connection.disconnect();
                    }
                }
            }
        }).start();
    }

3.此时,其它地方调用此联网方法时,将会需要重写这个抽象方法

HttpUtil.sendHttpRequest(address, new HttpCallbackListener() {
        @Override
        public void onFinish(String response) {
// 在这里根据返回内容执行具体的逻辑
        }
        @Override
        public void onError(Exception e) {
// 在这里对异常情况进行处理
        }
    });

完成了在不同的地方,都能在子线程中执行到onFinish()方法时,进行回调,立即取得子线程的计算结果并执行想要进行的操作。
但是回调的同时,仍然还是子线程中,并不允许进行UI操作。


从子线程进行UI操作:

Android为子线程中进行UI操作提供了一些封装方法:

  • Activity.runOnUiThread(Runnable action)
    如同字面意思般在工作线程中跳转到UI线程进程操作
  • View.post(Runnable action)
    直接给控件添加线程操作,此处可以更新UI
  • View.postDelayed(Runnable action, long delayMillis)
    方法2的延时版本
  • new Handler(Looper.getMainLooper()).post(Runnable action)
    获取了主线程的Looper进行线程操作,当然可以更新UI

举个栗子:

new Thread(new Runnable() {
    @Override
    public void run() {
        runOnUiThread(new Runnable() {
            @Override
            public void run() {
                mTestTextView.setText("赚钱好难");
            }
        });
    }
}).start();

3个方法使用起来很类似,不一一说明了。


多线程管理

线程池的操作

  • new Thread()的缺点

  • 每次new Thread()耗费性能

  • 调用new Thread()创建的线程缺乏管理,被称为野线程,而且可以无限制创建,之间相互竞争,会导致过多占用系统资源导致系统瘫痪。

  • 不利于扩展,比如如定时执行、定期执行、线程中断

  • 采用线程池的优点

  • 重用存在的线程,减少对象创建、消亡的开销,性能佳

  • 可有效控制最大并发线程数,提高系统资源的使用率,同时避免过多资源竞争,避免堵塞

  • 提供定时执行、定期执行、单线程、并发数控制等功能

Executor

android中线程池的概念来源于java中的Executor, 线程池真正的实现类是ThreadPoolExecutor,它间接实现了Executor接口。
Executor接口只有一个方法execute(),该方法用来执行线程中的操作。

Executor executor = new MyExecutor();
executor.execute(new RunnableTaskOne());
executor.execute(new RunnableTaskTwo());

ThreadPoolExecutor提供了一系列参数来配置线程池,通过不同的参数配置实现不同功能特性的线程池,android中的Executors类提供了4个工厂方法用于创建4种不同特性的线程池给开发者用.

newFixedThreadPool

创建一个可重用固定线程数的线程池,以共享的无界队列方式来运行这些线程。

ExecutorService executorService = Executors.newFixedThreadPool(5);
for (int i = 0; i < 20; i++) {
   Runnable syncRunnable = new Runnable() {
       @Override
       public void run() {
            Log.e(TAG, Thread.currentThread().getName());
       }
    };
    executorService.execute(syncRunnable);
}

运行结果:总共只会创建5个线程, 开始执行五个线程,当五个线程都处于活动状态,再次提交的任务都会加入队列等到其他线程运行结束,当线程处于空闲状态时会被下一个任务复用

特点:只有核心线程数,并且没有超时机制,因此核心线程即使闲置时,也不会被回收,因此能更快的响应外界的请求.

newCachedThreadPool

创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程

ExecutorService executorService = Executors.newCachedThreadPool(5);
for (int i = 0; i < 100; i++) {
   Runnable syncRunnable = new Runnable() {
       @Override
       public void run() {
            Log.e(TAG, Thread.currentThread().getName());
       }
    };
    executorService.execute(syncRunnable);
}

运行结果:缓存线程池大小是不定值,可以需要创建不同数量的线程,在使用缓存型池时,先查看池中有没有以前创建的线程,如果有,就复用.如果没有,就新建新的线程加入池中,缓存型池子通常用于执行一些生存期很短的异步型任务

特点:没有核心线程,非核心线程数量没有限制, 超时为60秒.

newScheduledThreadPool

创建一个定长线程池,支持定时及周期性任务执行
schedule(Runnable command,long delay, TimeUnit unit)创建并执行在给定延迟后启用的一次性操作

ExecutorService executorService = Executors.newScheduledThreadPool(5);
for (int i = 0; i < 200; i++) {
   Runnable syncRunnable = new Runnable() {
       @Override
       public void run() {
            Log.e(TAG, Thread.currentThread().getName());
       }
    };
    executorService.schedule(syncRunnable, 5000, TimeUnit.MILLISECONDS);
}

特点:核心线程数是固定的,非核心线程数量没有限制, 没有超时机制.主要用于执行定时任务和具有固定周期的重复任务.

SingleThreadExecutor

创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行

ExecutorService executorService = Executors.newScheduledThreadPool(5);
for (int i = 0; i < 200; i++) {
   Runnable syncRunnable = new Runnable() {
       @Override
       public void run() {
            Log.e(TAG, Thread.currentThread().getName());
       }
    };
    executorService.execute(syncRunnable);
}

特点:只有一个核心线程,并没有超时机制.意义在于统一所有的外界任务到一个线程中, 这使得在这些任务之间不需要处理线程同步的问题.

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 205,236评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,867评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,715评论 0 340
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,899评论 1 278
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,895评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,733评论 1 283
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,085评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,722评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 43,025评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,696评论 2 323
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,816评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,447评论 4 322
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,057评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,009评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,254评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,204评论 2 352
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,561评论 2 343

推荐阅读更多精彩内容

  • Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 171,478评论 25 707
  • java 接口的意义-百度 规范、扩展、回调 抽象类的意义-乐视 为其子类提供一个公共的类型封装子类中得重复内容定...
    交流电1582阅读 2,209评论 0 11
  • 【五律(新韵)】 沙地问春 -文/大漠 浅草露新芽,东风惹皱沙。 闲云栖古道,青鸟伴寒鸦。 时日还依旧,阶前问柳花...
    大漠qxy阅读 238评论 3 2
  • 昨天晚上睡得晚,今天早上我们都睡过头了,一睁开眼都6:30了,我把大宝喊起来让她赶紧洗漱,我就麻溜的去做饭,吃完饭...
    管婕妈妈阅读 122评论 0 0
  • 夏天就这样悄悄来临,随着温度的升高人的烦躁程度也在加深。 结束了一天疲惫的工作,吃好了晚饭准备休息,满身的困倦袭来...
    雨若云天阅读 369评论 1 1