Android并发编程与多线程

   一、Android线程基础

1.线程和进程

  • 一个进程最少一个线程,进程可以包含多个线程
  • 进程在执行过程中拥有独立的内存空间,而线程运行在进程内

2.线程的创建方式

  • new Thread:

        缺点:缺乏统一管理,可能无限制创建线程,相互之间竞争,可能占用过多的系统资源导致死机或OOM

    new Thread(new Runnable() {@Overridepublic void run() {}}).start();class MyThread extends Thread{@Overridepublic void run() {super.run();}}new MyThread().start();
  • AysncTask:轻量级异步任务工具类,提供任务执行的进度回调给UI线程

        使用场景:需要知道任务执行的进度,多个任务串行执行

        缺点:生命周期和宿主的生命周期不同步,可能发生内存泄漏,默认情况下任务串行执行

        作为用来替代Thread + Handler的辅助类,AsyncTask可以很轻松地执行异步任务并更新ui,但由于context泄露,回调遗漏,configuration变化导致崩溃,平台差异性等原因,在api 30(Android 11)中AsyncTask被正式废弃:

        使用execute方法,串行执行,即先来后到,如果其中有一条任务休眠,或者执行时间过长,后面的任务都将被阻塞

        使用内置THREAD_POOL_EXECUTOR线程池,并发执行

  • HandlerThread:适用于主线程需要和工作线程通信,或者持续性任务,比如轮询,所有任务串行执行

        缺点:不会像普通线程一样主动销毁资源,会一直运行,可能造成内存泄漏(可以定义成静态,防止内存泄漏)

  • IntentService:适用于任务需要跨界面读取任务执行的进、结果。比如:后台上传图片、批量操作数据库等。任务完成后,会自我结束,不需要手动stopService
  • ThreadPoolExecutor:适用快读出来大量耗时较短的任务场景
    • Executors.newCacheThreadPool();//线程可复用线程池
    • Executors.newFixedThreadPool();//固定线程数量线程池
    • Executors.newScheduleThreadPool();//可指定定时任务线程池
    • Executors.newSingleExecutor();//线程数量为1的线程池

3.线程的优先级

  • 线程的优先级具有继承性
  • 设置优先级的方法
    • java api:java.lang.Thread.setPriority(int newPriority);优先级必须为[1~10],优先级的值越高,获取CPU时间片的概率越高,UI线程的优先级为5  效果不是很明显
    • Android api:android.os.Process.setThreadPriority(int newPriority);优先级可设置[-20~19],优先级的值越低,获取时间片的概率越高,UI线程的优先级为-10 效果明显

4.线程的状态

  • NEW:初始状态,线程被新建,还没有调用start方法
  • RUNNABLE:运行状态,包括运行中和就绪
  • BLOCKED:阻塞状态,表示线程阻塞于锁
  • WAITING:等待状态,需要其他线程通知唤醒
  • TIME_WAITING:超时等待状态,表示可以在指定的时间超过后自行返回
  • TERMINATED:终止状态,表示当前线程已经执行完毕

关键方法:

  • wait:等待线程池,释放资源对象锁,可使用notify,notifyAll,或等待超时时间来唤醒
  • join:等待目标线程执行完后再执行此线程
  • yield:暂停当前正在执行的线程对象,不会释放当前线程持有的任何锁资源,使用优先级或更高优先级的线程有执行的机会,这个方法机会用不到
  • sleep:使调用线程进入休眠状态,一般情况下会释放线程锁对象,但如果在一个synchronized块中执行sleep,线程虽会休眠,但不会释放资源对象锁

5.线程间消息通讯

主线程向子线程发送消息

二、多线程开发核心知识点

1.线程并发安全

本质:能够让并发线程有序的运行(可能是先来后到排队,也可能被插队,同一时刻只能一个线程有权访问同步资源),线程执行的结果,能够对其它线程可见

2.线程安全的分类

  • 根据线程要不要锁住同步资源
    • 锁住:悲观锁  synchronized ReentrantLock
    • 不锁住:乐观锁  AtomicInteger  AtomicBoolean
  • 锁住同步资源失败要不要阻塞?
    • 阻塞:阻塞锁  synchronized ReentrantLock
    • 不阻塞:自旋锁  AtomicInteger  AtomicBoolean 
  • 获取资源锁时,要不要插队
    • 插队:公平锁  ReentrantLock
    • 不插队:非公平锁 synchronized ReentrantLock
  • 一个线程中的多个流程能不能获取同一把锁
    • 可重入锁: synchronized ReentrantLock
    • 不可重入锁
  • 多线程共享一把锁
    • 能:共享锁 RendLock
    • 不能:排他锁 WriteLock
  • 多线程竞争同步资源 synchronized
    • 不锁住资源,多个线程中只有一个能修改成功,其他会重试  无锁
    • 同一线程执行同步资源时自动获取锁   偏向锁
    • 多个线程竞争资源时,没有获取到资源的线程自选等待  轻量级锁
    • 多个线程竞争资源时,没有获取到资源的线程被阻塞等待唤醒  重量级锁

3.如何线程安全

AtomicInterger 原子包装类

  • CAS实现无锁数据更新,自旋的设计能够有效避免线程因阻塞-唤醒带来的系统资源开销
  • 适用场景:多线程计数,原子操作,并发数量小
  • 使用案例
        AtomicInteger atomicInteger = new AtomicInteger(1);atomicInteger.getAndIncrement();atomicInteger.getAndAdd(2);atomicInteger.getAndDecrement();atomicInteger.getAndAdd(-2);

volatile 可见性修饰

  • volatile修饰的成员变量在每次被线程访问时,都强迫从共享内存重新读取该成员的值,而且,当成员变量值发生变化时,强迫将变化的值重新写入共享内存
  • 缺点:不能保证原子性,不能解决非原子操作的线程安全性,性能不及原子类高
  • 使用案例
    volatile int count = 0;public void test() {// 赋值操作是原子性操作,对其他线程可见count = 1;//非原子操作,其他线程不可见count = count + 1;count++;}

synchronized

  • 锁方法。加在方法上,未获取到对象锁的其他线程都不可以访问该对象
  • 锁Class对象。加在static方法上相当于给Class对象加锁,哪怕是不同的Java对象实例,也需要排队执行
  • 锁代码块。未获取到对象锁的其他线程可以执行同步代码块之外的代码

优势:哪怕一个同步方法中出现了异常,那么JVM也能够为我们自动释放锁,能主动从而规避死锁,不需要开发者主动释放锁

劣势:

  • 必须要等到获取锁对象的线程执行完成,或出现异常,才能释放掉,不能中途释放锁,不能中断一个正在试图获取锁的线程
  • 多线程竞争的时候,不知道获取锁成功与否,不够灵活
  • 每个锁仅有单一的条件不能设定超时

ReentrantLock

悲观锁,可重入锁,公平锁,非公平锁

  • 基础用法:
        ReentrantLock lock = new ReentrantLock();try {lock.lock();//……} finally {lock.unlock();}//获取锁,获取不到会阻塞lock.lock();//尝试获取锁,成功返回truelock.tryLock();//在一定的时间内去不断尝试获取锁lock.tryLock(3000, TimeUnit.MICROSECONDS);//可使用Thread.interrupt()打断阻塞,退出竞争,让给其他线程lock.lockInterruptibly();
  • 可重入,避免死锁
    ReentrantLock lock = new ReentrantLock();public void doWork() {try {lock.lock();doWork();//递归调用,使得统一线程多次获得锁} finally {lock.unlock();}}
  • 公平锁:所有进入阻塞的线程排队依次均有机会执行

使用场景:交易

//传入true 就是公平锁,传入false 或者不传就是非公平锁 
ReentrantLock lock = new ReentrantLock(true);
  • 非公平锁:默认,允许线程插队,避免每一个线程都进入阻塞,在唤醒带来的性能开销。性能高,因为线程可以插队,但是会导致队列中可能存在线程饿死的情况,一直得不到锁,一直得不到执行

使用场景:synchronized,很多场景都是非公平锁

  • 进阶用法 -- Condition条件对象
  Condition worker = lock.newCondition();//进入阻塞,等待唤醒worker.await();//唤醒指定线程worker1.signal();

共享锁,排他锁

  • 共享锁:所有线程都可以同时获得,并发量高。如:读操作
  • 排他锁:同一时刻只能一个线程有权修改资源。如:写操作
ReentrantReadWriteLock.ReadLock
ReentrantReadWriteLock.WriteLock

三、正确使用锁和原子类

1.减少持锁时间

尽管锁在同一时间只能允许一个线程持有,其他想要占用锁的线程都得在临界区外等待锁的释放,这个等待的时间要尽可能的短

2.锁分离

读写锁分离,写锁才需要同步处理。对于大多数应用来说,读的场景更多一些,读写锁分离,可以提高系统性能

3.锁粗化

多次加锁,释放锁合并成一次

对于一些不需要同步的代码,但能很快执行完毕,前后都有锁,这种情况可以进行锁粗化,整合成一次锁请求,释放。(锁请求、释放是需要性能开销的)

四、线程池

1.优势

  • 减低资源消耗。通过重复利用已创建的线程减低线程创建和销毁造成的消耗;
  • 提高响应速度。当任务到达时,任务可以不需要等待线程创建就能立即执行;
  • 提高线程的可管理性。线程是稀有资源,如果无限制的创建,不仅会消耗系统资源,还会降低系统的稳定性,使用线程池可以进行统一的分配,调优和监控。

2.Java中默认的线程池

线程池的默认构建

       ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 20, 5, TimeUnit.SECONDS,new PriorityBlockingQueue<>());executor.execute(() -> {});// 源码public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler) {}

参数

  • corePoolSize:线程池中的核心线程数量
  • maximumPoolSize:最大能创建的线程数量
  • keepAliveTime:非核心线程最大的存活时间
  • unit:keepAliveTime的时间单位
  • workQueue:等待队列,当任务提交时,如果线程中线程数量大于等于corePoolSize的时候,把任务放入等待队列
  • threadFactory:线程创建工厂,默认使用Executors.defaultThreadFactory()来创建线程,线程具有相同的NORM_PRIORITY优先级并且是非守护线程
  • handler:线程池的饱和就决策略。如果阻塞队列满了并且没有空闲的线程,这时如果继续提交任务,就需要采取一种策略处理该任务

JUC包下提供的集中线程池

        // 单一线程数,同时只有一个线程存活,但是线程等待队列无界Executors.newSingleThreadExecutor();// 线程可复用线程池,核心线程数为0,最大可创建的线程数为Interger.max,线程复用存活时间为60sExecutors.newCachedThreadPool();// 固定线程数量的线程池Executors.newFixedThreadPool(5);// 可执行定时任务,延迟任务的线程池Executors.newScheduledThreadPool(5);

线程池的重要方法

//提交任务,交给线程池调度
void execute(Runnable command) //关闭线程池,等待执行任务完成,不接受新的任务,但可以继续执行池子中已添加到等待队列的任务
void shutdown()//关闭线程池,不等待执行任务完成,不接受新的任务,也不再处理等待队列中的任务打断正在执行的任务
void shutdownNow()//返回线程池中所有任务的数据
long getTaskCount()//返回线程池中已执行完毕的任务数量
long getCompletedTaskCount() //返回线程池中已创建的线程数量
int getPoolSize()//返回当前正在运行的线程数量
int getActiveCount()

execute提交任务流程

addWorker的工作任务

  1. 检查线程池状态,能否继续创建线程
  2. 把runnable封装成worker,添加到工作队列
  3. 启动新建的线程
  4. runWorker方法中开启whille循环,执行本次任务,本次任务结束后,去检查等待队列中,是否有任务,拿来继续执行,达到复用目的

retry:双层for循环流程控制,使用retry可以退出外层循环

        int count = 0;retry:for (int i = 0; i < 10; i++) {for (int j = 0; j < 10; j++) {count++;if (count == 3) {break;}if (count == 4){break retry;}}}

五、协程

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/189655.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

excel怎么能锁住行 和/或 列的自增长,保证粘贴公式的时候不自增长或者只有部分自增长

例如在C4单元格中输入了公式&#xff1a; 现在如果把C4拷贝到C5&#xff0c;D3会自增长为D4&#xff1a; 现在如果想拷贝的时候不自增长&#xff0c;可以先把光标放到C4单元格&#xff0c;然后按F4键&#xff0c;行和列的前面加上了$符号&#xff0c;锁定了&#xff1a; …

单稳态中间继电器\UEG/A-2H/220V 8A导轨安装 JOSEF约瑟

UEG系列中间继电器 UEG/A-2H2D中间继电器UEG/A-4H4D中间继电器UEG/A-2D中间继电器 UEG/A-2H中间继电器UEG/A-4H中间继电器UEG/A-4D中间继电器 UEG/A-6H中间继电器UEG/A-6D中间继电器UEG/A-8H中间继电器 UEG/A-10D中间继电器UEG/A-10H中间继电器UEG/A-2DPDT中间继电器 UEG/A-4DP…

C++多态原理揭秘

&#x1f388;个人主页:&#x1f388; :✨✨✨初阶牛✨✨✨ &#x1f43b;强烈推荐优质专栏: &#x1f354;&#x1f35f;&#x1f32f;C的世界(持续更新中) &#x1f43b;推荐专栏1: &#x1f354;&#x1f35f;&#x1f32f;C语言初阶 &#x1f43b;推荐专栏2: &#x1f354;…

值得你一生收藏的BMW宝马汽车底盘代号各个版本说明,方便今后查阅使用!

很少有汽车品牌像宝马一样&#xff0c;本属于内部交流使用的底盘代号&#xff08;Development Code&#xff09;&#xff0c;最终延伸为粉丝群体用以精准定位某一年代某一款车型的通用语。随着宝马加速推出新产品&#xff0c;每一年的底盘代号都在更新。你挚爱的强哥现将宝马所…

贝加莱MQTT功能

贝加莱实现MQTT Client端的功能库和例程 导入库和例程&#xff0c;AS Logical View中分别通过Add Object—Library&#xff0c;Add—Program插入MQTT库和例程。 将例程Sample放置于CPU循环周期中 定义证书存放路径&#xff0c;在AS Physical View 中&#xff0c;右击PLC—Con…

贝茄莱BR AS实时数据采集功能

实时数据采集功能在PLC系统调试过程中&#xff0c;有助于调试人员对变量变化进行监测&#xff0c;通过波形对比&#xff0c;反应不同变量间的相互作用。该测试目的在于验证贝加莱系统组态软件的实时数据采集功能。 贝加莱系统组态软件提供Trace功能&#xff0c;连接PLC&#x…

赛宁网安分靶场全力支持第三届“鹏城杯”攻防演练

为加速推进我国网络安全战略与数字化进程接轨&#xff0c;创新信息系统安全防护与网络安全技术研究模式&#xff0c;促进各行业网络安全建设的融合与协作&#xff0c;由鹏城实验室和中国网络空间安全人才教育论坛联合牵头举办的第三届“鹏城杯”联邦网络靶场协同攻防演练正式启…

Excel 文件比较工具 xlCompare 11.01 Crack

比较两个 Excel 文件之间的差异 xlCompare. xlCompare.com 是性能最佳的 Excel diff 工具&#xff0c;用于比较两个 Excel 文件或工作表并在线突出显示差异。xlCompare 包括免费的在线 Excel 和 CSV 文件比较服务以及用于比较和合并 Excel 文件的强大桌面工具。如果您想在线了…

这就是不创业的最大的原因,机器视觉兄弟们创业要谨慎,为什么99.99%机器视觉公司老板是销售人员?

机器视觉公司&#xff0c;99%公司实行销售优先原则&#xff0c;企业老板99%从销售人员中产生。所以机器视觉兄弟们创业要谨慎。 企业的本质就是通过销售获得利润的组织&#xff0c;销售是立足之本&#xff0c;没有销售&#xff0c;创业就是耍流氓。因此&#xff0c;企业的一切…

Linux CentOS 8(DHCP的配置与管理)

Linux CentOS 8&#xff08;DHCP的配置与管理&#xff09; 目录 一、项目介绍二、DHCP服务简介三、DHCP工作原理四、配置DHCP服务4.1 项目配置准备4.2 dhcpd配置文件框架与参数说明4.3 登录客户机验证4.4 客户端IP地址的释放与重新申请4.5 保留特定IP地址 一、项目介绍 当计算…

MATLAB Simulink和S7-1200PLC MOBUSTCP通信

MATLAB Simulink和SMART PLC OPC通信详细配置请查看下面文章链接: MATLAB和西门子SMART PLC OPC通信-CSDN博客文章浏览阅读749次,点赞26次,收藏2次。西门子S7-200SMART PLC OPC软件的下载和使用,请查看下面文章Smart 200PLC PC Access SMART OPC通信_基于pc access smart的…

asp.net 学校资源信息管理系统VS开发sqlserver数据库web结构c#编程计算机网页项目

一、源码特点 asp.net 学校资源信息管理系统 是一套完善的web设计管理系统&#xff0c;系统具有完整的源代码和数据库&#xff0c;系统主要采用B/S模式开发。 asp.net学校资源管理系统 二、功能介绍 本系统使用Microsoft Visual Studio 2019为开发工具&#xff0c;SQL …