- 浏览: 453343 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
July01:
最近了解到一款StratoIO打印控件,功能如下:1、Html ...
JS操作XMLDOM(遍历和打印) -
lliiqiang:
我这边只要出现图表组件就报告2032号错误。
Flex 出现 Error #2032 是什么意思 -
全保生:
感谢!方法一:(已确认 可行)String username ...
jsp 的url传参中文乱码问题解决办法 -
dy804731771:
谢谢您的分享,对我有帮助
兼容的带样式的INPUT -
huang305585796:
火影头像好屌
FusionCharts统计图导出为图片或pdf
>>//一个简单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 (尚学堂)
/*
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 (尚学堂)
发表评论
-
【Blue-Bird】邮件群发系统
2013-03-25 21:46 1194【Blue-Bird】邮件发送系统,是我研发的一个Java ... -
java获取本地磁盘(过滤掉U盘和软盘等)
2012-10-16 09:40 3936File[] _files = File.listRoo ... -
XmlDOM 小结
2012-08-10 16:53 1026/* 获取节点: - xmlDoc.getElem ... -
eclipse内存溢出处理办法
2012-07-31 14:44 3795"java.lang.OutOfMemoryErr ... -
tomcat使用xml文件部署项目
2012-02-02 21:53 1178<Context path="/emss ... -
String.format
2011-12-02 23:09 1004String[] arr =new String[2]; ... -
配置一个最简洁的DWR
2011-04-04 16:31 995期工作: 1.dwr官网下载dwr.jar(http://d ... -
通过xml文件在tomcat中部署项目&取消保存session.ser的配置
2011-03-29 10:34 1735<Context path="/anjian& ... -
plsql操作oracle数据库小结
2011-03-28 18:05 5616登录oracle D:\>sqlplus ... -
java编程思想读书笔记
2011-03-17 11:06 10821 用句柄操作对象:句柄也叫引用或者指针。 可将这一情 ... -
CVSNT 用户单一验证方式建设文档
2011-03-01 10:29 13731 配置cvs服务 CVSNT Control Panel ... -
EasyT.java(20110223版本)
2011-02-23 14:56 1524package org.hdht.util; impor ... -
java杂谈
2011-02-23 14:47 1120hibenate配置文件定义datas ... -
Spring下的BaseHibernateDAO
2011-02-23 14:46 3556package com.accp.myzf.hibernate ... -
带事务得spring配置文件
2011-02-23 14:44 1134<?xml version="1.0" ... -
单利模式,堆栈,队列
2011-02-23 14:43 1070单利实例-------------- using Syste ... -
线程3
2011-02-23 14:41 1041配置java环境变量: 1指定jdk的bin目录路径:pat ... -
线程2
2011-02-23 14:39 1035>>3内部class类继承Thread的线程实现方 ... -
基于TCP的Socket编程
2011-02-23 14:35 1131>>Socket相关的理解: 1>TCP:拨 ... -
基于UDP的Socket编程
2011-02-23 14:33 16961>>基于UDP的Socket编程用到的类和方法 ...
相关推荐
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 ...
STM32可以有STM32CubeMX轻松移植THreadX,雅特力从AT43F435/437系列开始不能完全兼容STM32,用不了THreadX了。 本移植采用最新(截至2023年3月12号)的AT32F435/437固件库V2.1.2,THreadX版本V6.2.1;依照雅特力官方...
赠送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份)。 C RTOS中的RUST应用 CherryUSB协议栈的原理与使用 RISCV指令集开源软件生态 RNDIS设备驱动框架 RT-Thread 电源管理组件 RT-Thread 构建配置系统 RT-Thread ...
System.out.println("Activity-->"+ Thread.currentThread().getName()); } Runnable r = new Runnable() { @Override public void run() { // TODO Auto-generated method stub try { Thread...
是第一次在C#中接触Thread,自己研究了一下其中Thread.Join()这个方法,下面谈谈自己的理解。 Thread.Join()在MSDN中的解释很模糊:Blocks the calling thread until a thread terminates 有两个主要问题: ...
RT-Thread实时操作系统是一个分层的操作系统,它包括了: 底层移植、驱动层,这层与硬件密切相关,由Drivers和CPU移植相构成。 硬实时内核,这层是RT-Thread的核心,包括了内核系统中对象的实现,例如多线程及其...
ThreadX操作系统 CHM格式的帮助文档,能够方便地查阅ThreadX的所有函数实现,函数定义,函数描述,函数实例,并且分类整理好了各个类别的函数。 各个相关联的函数API之间支持链接跳转,使用起来相当方便。 格式与VC...
赠送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——Express Logic 公司高性能实时内核的详尽信息。 指南之意义 本手册适用于嵌入式实时软件的开发者。开发者应熟悉标准实时操作系统的功能及C 程序设计。 结构 手册包括七章,五个附录以及...
晟睿STM32F103ZET6开发板跑RT Thread,内核为1.2.0,GUI为0.8版本,可以下载到板子上跑。 1、TFT根据RT Thread驱动框架编写,FSMC总线,可直接用。适合常用的9320、9325、9328TFT驱动。 2、SPI W25Qxx Nor flash驱动...
本资源是我的RT-Thread专栏应用篇《RT-Thread 应用篇 — 在STM32L051上使用 RT-Thread》的工程源码: 一个简单的应用:无线温湿度传感器 一个小内存的芯片:STM32L051C8T6 一个小而美丽的物联网操作系统:RT-Thread ...
继承Thread类: 1必须重写run 方法:里面放置的实际的线程体 2 启动线程: 3创建Thread对象 4调用Thread对象的start 方法启动线程
RTOS RT-THREAD标准库参考工程
经过了努力,查找了很多资料,终于可以利用STM32的SDIO操作文件系统读写了,但是发现为文件命名有问题,要熟悉rt_thread系统的可以上他官网下载说明书,地址:http://www.rt-thread.org/ 算是对它的一个宣传吧。 这里...
RT-Thread,全称是 Real Time-Thread,顾名思义,它是一个嵌入式实时多线程操作系统,基本属性之一是支持多任务,允许多个任务同时运行并不意味着处理器在同一时刻真地执行了多个任务。事实上,一个处理器核心在某一...
ThreadX是优秀的实时嵌入式操作系统,本资源是ThreadX的win32开发环境,用于vs2005,可以简单的在vs2005中编写threadx程序,已经使用过,绝对可以使用
rtthread nano的模板,有基本的内核部分,可以完成线程调度、信号量传递等等
rt-thread入门教程PPT
s5pv210 threadx ucgui touch移植