`
accpxudajian
  • 浏览: 453343 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Thread

    博客分类:
  • Java
阅读更多
>>//一个简单Thread缓冲池的实现  
/*
Queue的一个经典实现是使用一个循环数组(这个实现在很多数据结构的书上都有介绍),如一个大小为size的数组,这个循环数组可以被想象成首尾相连的一个环。oldest指向Queue中最老的数据所在的位置,next指向下一个可以放新数据的位置。
放入一个新数据到next的位置后,需要更新next:next = (next + 1) % size;
从oldest位置取出一个数据后,需要更新oldest:oldest = (oldest + 1) % size;
当oldest == next的时候,Queue为空,
当(next + 1) % size == oldest的时候,Queue为满。
(注意:为了区分Queue为空和为满的情况,实际上Queue里面最多能放size-1个数据。)
因为这个Queue会同时被多个线程访问,需要考虑在这种情况下Queue如何工作。首先,Queue需要是线程安全的,可以用Java里的synchronized关键字来确保同时只有一个Thread在访问Queue.
我们还可以注意到当Queue为空的时候,get操作是无法进行的;当Queue为满的时候,put操作又是无法进行的。在多线程访问遇到这种情况时,一般希望执行操作的线程可以等待(block)直到该操作可以进行下去。比如,但一个Thread在一个空Queue上执行get方法的时候,这个 Thread应当等待(block),直到另外的Thread执行该Queue的put方法后,再继续执行下去。在Java里面,Object对象的 wait(),notify()方法提供了这样的功能。
*/
class SyncQueue {
protected Object[] array;
      protected int next;
      protected int oldest;
      protected int size;

       public SyncQueue(int size) {
         array = new Object[size];
         size = size;
  //oldest指向Queue中最老的数据所在的位置,next指向下一个可以放新数据的位置。
  oldest = 0;   //最后可以取走得线程的索引,就是刚刚取走的线程后边的那个线程。
  next = 0; //可以放入新线程的索引。就是刚刚放入的线程的索引的下一位
}
//向线程缓冲池中放入新的线程
//先判断缓冲池是否已经满了,如果满了则等待wait线程执行结束再放入
//涉及到wait和notify方法得都的是在同步synchronized方法里或者同步块里
public synchronized void put(Object o) {
  while (full()) {
   try {
    wait();
   } catch (InterruptedException ex) {
    throw new ExceptionAdapter(ex);
   }
  }
  //线程池未满,继续放入线程
  array[next] = o;
  next = (next + 1) % size;//计算下一个可放入线程的位置,对size求余是为了保证不超出数组范围。且可以循环使用。
  notify();//clinet放入线程后通知server取出线程去执行
}
//从缓冲池中取出线程 同步synchronized方法
//如果此时线程池为空,则等待放入线程,否则取出线程并通知client放入线程
public synchronized Object get() {
  while (empty()) {
   try {
    wait(); //等待放入线程
   } catch (InterruptedException ex) {
    throw new ExceptionAdapter(ex);
   }
  }
  Object ret = array[oldest];//获得最有一个线程
  oldest = (oldest + 1) % size;//更改下一个可取走线程的位置,对size求余是为了保证不超出数组范围,且可以循环使用。
  //server取走线程后 通知client放入线程
  notify();
  //返回最有一个线程对象去执行
  return ret;
}
//判断线程池是否是空的
protected boolean empty() {
//如果下一个可放入线程的位置就是最后一个可取走的线程的位置,则表示线程池是空的
  return next == oldest;
}
//判断线程池是否是满得
protected boolean full() {
  //如果下一个可放入线程的位置+1对线程池的大小取余等于最后一个可取走的线程得位置,表示线程池是满地。
  return (next + 1) % size == oldest;

}
}
/*
next = (next + 1) % size就相当于:(oldest一样,保证不超过数组范围,又可以持续循环)
next ++;
//如果加到最大值,重新从0开始
if(next==size)
{
  next =0;
}
*/
/*
Thread缓冲池得原理:定义一个大小为size的Object数组,访队列方式添加和取出数据(先进先出),用next表示可以放入下一个线程的位置(如已经有了1 2 3,则next=4),用oldest表示下一个可以读取线程的位置(如 1234 已经把2取走,则下一个可以取走的oldest=3),client每放入一个新的线程之前,判断缓冲池是否已经满了,满了就等待(wait)
server取走线程执行,否则放入线程,并修改可以放入下一个线程的位置 (方法是next =(next+1)%size 对size求余保证不超过数组范围,又可以持续循环),然后通知(notify)server取走线程对象。
server每次读取一个线程之前, 先判断线程池是否是空的,空的就等待(wait)client放入线程,否则取走最先放入的那个线程(例如数组1 2 3 4,读取oldest=1的线程对象,此时可放入next=5 ), 然后修改可读取线程对象的位置(方法是oldest =(oldest+1)%size 对size求余保证不超过数组范围,又可以持续循环),最后通知(notify)client继续放入线程*/


2>>多线程编程
   随着计算机技术的发展,编程模型也越来越复杂多样化。但多线程编程模型是目前计算机系统架构的最终模型。随着CPU主频的不断攀升,X86架构的硬件已经成为瓶,在这种架构的CPU主频最高为4G。事实上目前3.6G主频的CPU已经接近了顶峰。   如果不能从根本上更新当前CPU的架构(在很长一段时间内还不太可能),那么继续提高CPU性能的方法就是超线程CPU模式那么,作业系统、应用程序要发挥CPU的最大性能,就是要改变到以多线程编程模型为主的并行处理系统和并发式应用程序
  所以,掌握多线程编程模型,不仅是目前提高应用性能的手段,更是下一代编程模型的核心思想。多线程编程的目的,就是"最大限度地利用CPU资源",当某一线程的处理不需要占用CPU而只和I/O,OEMBIOS等资源打交道时,让需要占用CPU资源的其它线程有机会获得CPU资源。从根本上说,这就是多线程编程的最终目的。

2>>线程对象和线程的区别:  线程对象是可以产生线程的对象。比如在java平台中Thread对象,Runnable对象
        线程,是指正在执行的一个指点令序列。在java平台上是指从一个线程对象的start()开始,运行run方法体中的那一段相对独立的过程。在JAVA中,线程对象是JVM产生的一个普通的Object子类。而线程是CPU分配给这个对象的一个运行过程。我们说"个线程在干什么",不说"一个线程对象在干什么"

3>>JVM;Java Virtual Machine(Java虚拟机)。运行main方法:JVM进程被启动,在同一个JVM进程中,有且只有一个进程,就是它自己。然后在这个JVM环境中,所有程序的运行都是以线程来运行。JVM最先会产生一个主线程,由它来运行指定程序的入口点。在这个程序中,就是主线程从main方法开始运行。当main方法结束后,主线程运行完成。JVM进程也随之退出。(每个程序只有一个main方法,所以它只对应一个进程,但对应多个线程)

>>4多线程Java 应用程序构建(Concurrent Programming)
1 JSR-166(Java concurrency utilities),是Java5.0的一部分,通过着重在宽度并提供跨域大范围并发编程风格的重要功能,大大简化了在Java中并发应用程序的开发。
注意:start()方法的调用后并不是立即执行多线程代码,而是使得该线程变为可运行态(Runnable),什么时候运行是由操作系统决定的。(和线程的时间片有关系).
>>随机数休眠进程:Thread.sleep((int) Math.random() * 10);

>>同步方法和方法调用的区别:
public synchronized void m1(){a =1000;}
public synchronized  void m2() {  a =5000;}
public void m3() {  a =5000;}
当m1执行时,m2无法进行,m3可以,因为m2的进行要对a进行加锁,但此时m1已经将a加锁,所以m2无法进行。而m3的进行无需对m3进行加锁,所以m3可以正常的进行。也就是说:不是同步的方法可以访问正在同步的方法的变量资源
>>加锁的变量的使用机制(自己理解)
加锁的同步方法或者同步块,对方法体内的变量资源独占,当其他的方法访问变量时,需要等待该方法对变量资源解锁,也就是该方法结束,也就是方法运行到"}"(与数据库的修改操作需要同步,查询操作不用同步)

>>同步方法的执行过程特点
public synchronized void m2()
{
语句1;
语句2;
语句3;
语句4;
。。。
}
执行时,语句1 2 3 4不允许被别的线程打断,即执行完1就走2,然后就走3,紧接著4

网上资源:
http://www.enet.com.cn/eschool/zhuanti/java/ (孙鑫)
http://v.youku.com/v_show/id_XNTMzMTY4MTI=.html (尚学堂)
分享到:
评论

相关推荐

    thread thread thread thread

    thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread thread ...

    AT32F435移植THreadX;AT32F437移植THreadX,移植最新版THreadX

    STM32可以有STM32CubeMX轻松移植THreadX,雅特力从AT43F435/437系列开始不能完全兼容STM32,用不了THreadX了。 本移植采用最新(截至2023年3月12号)的AT32F435/437固件库V2.1.2,THreadX版本V6.2.1;依照雅特力官方...

    transmittable-thread-local-2.12.1-API文档-中文版.zip

    赠送jar包:transmittable-thread-local-2.12.1.jar; 赠送原API文档:transmittable-thread-local-2.12.1-javadoc.jar; 赠送源代码:transmittable-thread-local-2.12.1-sources.jar; 赠送Maven依赖信息文件:...

    2022年RT-Thread全球技术大会国内专场PPT合集(31份).zip

    2022年RT-Thread全球技术大会国内专场PPT合集(31份)。 C RTOS中的RUST应用 CherryUSB协议栈的原理与使用 RISCV指令集开源软件生态 RNDIS设备驱动框架 RT-Thread 电源管理组件 RT-Thread 构建配置系统 RT-Thread ...

    Android:Handler的post()方法和Thread的start()方法执行Thread的run()方法的区别

    System.out.println("Activity-->"+ Thread.currentThread().getName()); } Runnable r = new Runnable() { @Override public void run() { // TODO Auto-generated method stub try { Thread...

    关于C#中Thread.Join()的一点理解

    是第一次在C#中接触Thread,自己研究了一下其中Thread.Join()这个方法,下面谈谈自己的理解。  Thread.Join()在MSDN中的解释很模糊:Blocks the calling thread until a thread terminates  有两个主要问题: ...

    rt-thread源码

    RT-Thread实时操作系统是一个分层的操作系统,它包括了: 底层移植、驱动层,这层与硬件密切相关,由Drivers和CPU移植相构成。 硬实时内核,这层是RT-Thread的核心,包括了内核系统中对象的实现,例如多线程及其...

    ThreadX API查询手册.chm

    ThreadX操作系统 CHM格式的帮助文档,能够方便地查阅ThreadX的所有函数实现,函数定义,函数描述,函数实例,并且分类整理好了各个类别的函数。 各个相关联的函数API之间支持链接跳转,使用起来相当方便。 格式与VC...

    transmittable-thread-local-2.12.2-API文档-中文版.zip

    赠送jar包:transmittable-thread-local-2.12.2.jar; 赠送原API文档:transmittable-thread-local-2.12.2-javadoc.jar; 赠送源代码:transmittable-thread-local-2.12.2-sources.jar; 赠送Maven依赖信息文件:...

    ThreadX中文学习手册

    本手册提供了有关ThreadX——Express Logic 公司高性能实时内核的详尽信息。 指南之意义 本手册适用于嵌入式实时软件的开发者。开发者应熟悉标准实时操作系统的功能及C 程序设计。 结构 手册包括七章,五个附录以及...

    RT-Thread1.2.0.rar_STM32 RT-Thread_STM32 SPI TF卡_STM32的SDIO例程_s

    晟睿STM32F103ZET6开发板跑RT Thread,内核为1.2.0,GUI为0.8版本,可以下载到板子上跑。 1、TFT根据RT Thread驱动框架编写,FSMC总线,可直接用。适合常用的9320、9325、9328TFT驱动。 2、SPI W25Qxx Nor flash驱动...

    在STM32L051C8上使用 RT-Thread Nano 实例项目源码

    本资源是我的RT-Thread专栏应用篇《RT-Thread 应用篇 — 在STM32L051上使用 RT-Thread》的工程源码: 一个简单的应用:无线温湿度传感器 一个小内存的芯片:STM32L051C8T6 一个小而美丽的物联网操作系统:RT-Thread ...

    Thread实现多线程

    继承Thread类: 1必须重写run 方法:里面放置的实际的线程体 2 启动线程: 3创建Thread对象 4调用Thread对象的start 方法启动线程

    RTThread Stm32 标准库参考工程.zip_RT-Thread STD库_rtos stm32_rtthread_rt

    RTOS RT-THREAD标准库参考工程

    STM32基于rt_thread操作系统的SDHC卡文件系统读写以及RT_GUI+触屏

    经过了努力,查找了很多资料,终于可以利用STM32的SDIO操作文件系统读写了,但是发现为文件命名有问题,要熟悉rt_thread系统的可以上他官网下载说明书,地址:http://www.rt-thread.org/ 算是对它的一个宣传吧。 这里...

    RT-Thread Studio-v2.2.6-setup-x86-64-202305191040

    RT-Thread,全称是 Real Time-Thread,顾名思义,它是一个嵌入式实时多线程操作系统,基本属性之一是支持多任务,允许多个任务同时运行并不意味着处理器在同一时刻真地执行了多个任务。事实上,一个处理器核心在某一...

    threadX的VC开发环境

    ThreadX是优秀的实时嵌入式操作系统,本资源是ThreadX的win32开发环境,用于vs2005,可以简单的在vs2005中编写threadx程序,已经使用过,绝对可以使用

    rt-thread-3.1.3_rtthread_RT-Thread_nano_rtthreadopenocd_RT-Threa

    rtthread nano的模板,有基本的内核部分,可以完成线程调度、信号量传递等等

    rt-thread入门教程PPT

    rt-thread入门教程PPT

    threadx ucgui touch移植

    s5pv210 threadx ucgui touch移植

Global site tag (gtag.js) - Google Analytics