- 浏览: 439624 次
- 性别:
- 来自: 吉林→上海
文章分类
- 全部博客 (174)
- Java基础-接口与内部类 (5)
- Java基础-流与文件 (10)
- Java基础-JDBC (12)
- Java基础-XML解析 (7)
- Java基础-多线程 (11)
- Java基础-网络 (6)
- Java基础-注解 (5)
- Hibernate 研究记录 (7)
- JavaScript 研究记录 (6)
- ECMAScript 研究记录 (7)
- CSS 研究记录 (9)
- Maven 研究记录 (8)
- SQL 随笔 (5)
- 权限控制和单点登陆 (8)
- Hadoop 研究记录 (6)
- 随想杂谈 (33)
- JAVA EE (4)
- 测试 (3)
- Redis (10)
- Memcached (2)
- MongoDB (6)
- ElasticSearch (3)
最新评论
-
sgq0085:
无尘灬 写道楼主,在吗?可以加你qq咨询一下问题吗?公司禁用Q ...
Shiro通过Redis管理会话实现集群 -
无尘灬:
楼主,在吗?可以加你qq咨询一下问题吗?
Shiro通过Redis管理会话实现集群 -
zhouminsen:
感谢楼主的无私奉献
Shiro通过Redis管理会话实现集群 -
tonny1228:
经测试还是运行在local
远程调用执行Hadoop Map/Reduce -
asdhobby:
楼主,个人感觉每次调用SessionDAO的doUpdate方 ...
Shiro通过Redis管理会话实现集群
java.lang.Runnable 接口
void run() 必须重写这个方法,并在这个方法中提供所要执行的任务。
java.lang.Thread 类,该类实现了Runnable接口
构造
Thread(Runnable target) 构造一个新线程,用于调用给定target的run()方法
方法
1.启动和中断线程
void start() : 启动这个线程,将引发调用run()方法,这个方法将立即返回,并且新线程将并行运行。
void run() : 调用关联Runnable的run方法。
static void sleep(long millis,int nanos) : 休眠给定的毫秒数 需要捕获sleep方法可能抛出的异常InterruptedException
millis - 以毫秒为单位的休眠时间
nanos - 要休眠的另外 0-999999 纳秒
void interrupt() : 中断线程,如果当前线程无法修改该线程(如果不是中断状态会调用checkAccess)
抛出: SecurityException
void checkAccess() : 判定当前运行的线程是否有权修改该线程 如果有安全管理器,则调用其 checkAccess 方法,并将该线程作为其参数
抛出: SecurityException 如果不允许当前线程访问该线程。
boolean isInterrupted() : 测试线程是否已经中断。线程的中断状态 不受该方法的影响。返回:如果该线程已经中断,则返回 true;否则返回 false。
static boolean interrupted() : 检测当前的线程是否被中断,并清除该线程的中断状态。
2.线程状态
void join() : 等待该线程终止。
void join(long millis) : 等待该线程终止的时间最长为 millis 毫秒。
Thread.State getState() : 返回该线程的状态。 该方法用于监视系统状态,不用于同步控制。
3.线程优先级
setPriority(int) : 设置线程优先级
int MIN_PRIORITY 线程的最小优先级。最小优先级值为1.
int NORM_PRIORITY 线程的默认优先级。缺省优先级值为5.
int MAX_PRIORITY 线程的最大优先级。最大优先级值为10。
static void yield() : 导致当前执行线程处于让步状态。如果有其他的可运行线程具有至少与此线程同样高的优先级,那么这些线程接下来会被调度。
4.守护线程
setDaemon(boolean) : 设置该线程标记为守护线程或用户线程。必须在线程启动之前调用。当正在运行的线程都是守护线程时,Java 虚拟机退出。
isDaemon : 测试该线程是否为守护线程。如果该线程是守护线程,则返回 true;否则返回 false。
5.未捕获异常
static void setDefaultUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh) : 设置当线程由于未捕获到异常而突然终止,并且没有为该线程定义其他处理程序时所调用的默认处理程序。
static Thread.UncaughtExceptionHandler getDefaultUncaughtExceptionHandler() : 返回线程由于未捕获到异常而突然终止时调用的默认处理程序。(获取未捕获异常的处理器),如果不设置返回null。
void setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh) : 设置该线程由于未捕获到异常而突然终止时调用的处理程序。
Thread.UncaughtExceptionHandler getUncaughtExceptionHandler() : 获取未捕获异常的处理器,如果未设置返回java.lang.ThreadGroup
已过时方法
【已过时】void stop() : 停止该线程
【已过时】void suspend() : 暂停这一线程的运行。
【已过时】void resume() : 恢复线程。
接口 Thread.UncaughtExceptionHandler
方法 void uncaughtException(Thread t, Throwable e) : 当一个线程因未捕获异常而终止,按规定要讲客户报告记录到日志中。
参数 t:由于未捕获异常而终止的线程 e:未捕获异常的对象
类 ThreadGroup
void uncaughtException(Thread t, Throwable e) :
如果此线程组有一个父线程组,那么调用此父线程组的 uncaughtException 方法时带有两个相同的参数。
否则,此方法将查看是否安装了默认的未捕获异常处理程序,如果是,则在调用其 uncaughtException 方法时带有两个相同的参数。
否则,此方法将确认 Throwable 参数是否为一个 ThreadDeath 实例。如果是,则不会做任何特殊的操作。否则,在从线程的 getName 方法返回时,会使用 Throwable 的 printStackTrace 方法,将包含线程名称的消息和堆栈跟踪信息输出到标准错误流。
接口 java.util.concurrent.locks.Lock
void lock() : 获取这个锁,如果锁同时被另一个线程拥有则发生阻塞
boolean tryLock() : 尝试获得锁而没有发生阻塞。如果成功返回true,这个方法会抢夺可用的锁,即使该锁有公平加锁策略,即使其他线程已经等待很久。
boolean tryLock(long time, TimeUnit unit) : 尝试获得锁,阻塞时间不会超过给定的值;如果成功返回true。
void lockInterruptibly() : 获得锁,但是会不确定的发生阻塞。如果线程被中断,抛出一个InterruptedException异常。
void unlock() : 释放这个锁
类 java.util.concurrent.locks.ReentrantLock
ReentrantLock() : 构建一个可以用来保护临界区的可重入锁。
ReentrantLock(boolean fair) : 构建一个带有公平策略的锁。一个公平锁偏爱等待时间最长的线程。但是这一公平保证将大大降低性能,所以默认情况下,锁没有强制为公平的。
类 java.util.concurrent.locks.ReentrantReadWriteLock
Lock readLock() : 得到一个可以被多个线程读操作公用的读锁,但会排斥所有写操作。
Lock writeLock() : 得到一个写锁,排斥所有其他的读操作和写操作。
接口 java.util.concurrent.locks.Condition
void await() : 将该线程放到条件的等待集中
void await(long time, TimeUnit unit) : 进入该条件的等待集,直到线程从等待集中移出,或等待了指定时间之后才解除阻塞。如果因为等待时间到了而返回就返回false,否则返回true。
void awaitUninterruptibly() : 进入该条件的等待集,直到线程从等待集移出才解除线程。如果线程被中断,该方法不会抛出InterruptException。
void signalAll() : 唤醒所有等待线程
void signal() : 唤醒一个等待线程
类 java.lang.Object
void notifyAll() : 唤醒在此对象监视器上等待的所有线程。该方法只能在同步方法或同步块内部使用。如果当前线程不是锁的持有者,抛出IllegalMonitorStateException异常。
void notify() : 唤醒在此对象监视器上等待的单个线程。该方法只能在同步方法或同步块内部使用。如果当前线程不是锁的持有者,抛出IllegalMonitorStateException异常。
void wait() : 导致当前线程等待,直到它被通知。该方法只能在同步方法或同步块内部使用。如果当前线程不是锁的持有者,抛出IllegalMonitorStateException异常。
void wait(long millis) : 在其他线程调用此对象的 notify() 方法或 notifyAll() 方法,或者超过指定的时间量前,导致当前线程等待。
void wait(long millis, int nanos) : 在其他线程调用此对象的 notify() 方法或 notifyAll() 方法,或者超过指定的时间量前,导致当前线程等待。millis毫秒数,nanos<1 000 000 纳秒数。
类 java.util.concurrent.ArrayBlockingQueue<E>
类 java.util.concurrent.ConcurrentLinkedQueue<E>
构造 ConcurrentLinkedQueue<E>() : 构造一个可以被多线程安全访问的无边界非阻塞的队列。
类 java.util.concurrent.ConcurrentHashMap<K,V>
构造 ConcurrentHashMap() : 创建一个带有默认初始容量 (16)、加载因子 (0.75) 和 concurrencyLevel (16) 的新的空映射。
ConcurrentHashMap(int initialCapacity, float loadFactor, int concurrencyLevel) : 创建一个带有指定初始容量、加载因子和并发级别的新的空映射。
initialCapacity : 集合的初始容量,默认为16
loadFactor : 控制调整:如果每一个桶的平均负载超过这个因子,表的大小会被从新调整。默认值为0.75
concurrencyLevel : 并发写者线程的估计数目
类 java.util.concurrent.ConcurrentSkipListSet
构造 ConcurrentSkipListSet() : 构造一个新的空 set,该set按照元素的自然顺序对其进行排序。或元素实现comparable接口。
构造 ConcurrentSkipListSet(Comparator<? super E> comparator) : 构造一个新的空set,该set按照指定的比较器对其元素进行排序。
类 java.util.concurrent.ConcurrentSkipListMap<K,V>
构造 ConcurrentSkipListMap() : 构造一个新的空映射,该映射按照键的自然顺序进行排序。
构造 ConcurrentSkipListMap(Comparator<? super K> comparator) : 构造一个新的空映射,该映射按照指定的比较器进行排序。
类 java.util.Conllections
static<E> Conllection<E> synchronizedConllection(Collection<E> c)
static<E> List synchronizedList(List<E> c)
static<E> Set synchronizedSet(Set<E> c)
static<E> SortedSet synchronizedSortedSet(SortedSet<E> c)
static<K, V> Map<K, V> synchronizedMap(Map<K, V> c)
static<K, V> SortedMap<K, V> synchronizedSortedMap(SortedMap<K, V> c)
类 java.util.concurrent.ConcurrentLinkedQueue<E>
构造 ConcurrentLinkedQueue<E>() : 构造一个可以被多线程安全访问的无边界非阻塞的队列。
类 java.util.concurrent.ConcurrentHashMap<K,V>
构造 ConcurrentHashMap() : 创建一个带有默认初始容量 (16)、加载因子 (0.75) 和 concurrencyLevel (16) 的新的空映射。
ConcurrentHashMap(int initialCapacity, float loadFactor, int concurrencyLevel) : 创建一个带有指定初始容量、加载因子和并发级别的新的空映射。
initialCapacity : 集合的初始容量,默认为16
loadFactor : 控制调整:如果每一个桶的平均负载超过这个因子,表的大小会被从新调整。默认值为0.75
concurrencyLevel : 并发写者线程的估计数目
类 java.util.concurrent.ConcurrentSkipListSet
构造 ConcurrentSkipListSet() : 构造一个新的空 set,该set按照元素的自然顺序对其进行排序。或元素实现comparable接口。
构造 ConcurrentSkipListSet(Comparator<? super E> comparator) : 构造一个新的空set,该set按照指定的比较器对其元素进行排序。
类 java.util.concurrent.ConcurrentSkipListMap<K,V>
构造 ConcurrentSkipListMap() : 构造一个新的空映射,该映射按照键的自然顺序进行排序。
构造 ConcurrentSkipListMap(Comparator<? super K> comparator) : 构造一个新的空映射,该映射按照指定的比较器进行排序。
类 java.util.concurrent.Executors
static ExecutorService newCachedThreadPool() : 返回一个带缓存的线程池,该池在必要的时候创建线程,在线程空闲60秒后终止线程。
static ExecutorService newFixedThreadPool(int nThreads) : 返回一个线程池,该池中的线程数由参数指定。
static ExecutorService newSingleThreadPool() : 返回一个执行器,它在一个单个线程中依次执行各个任务。
static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) : 返回一个线程池,它使用给定的线程数来调度任务。
static ScheduledExecutorService newSingleThreadScheduledExecutor(ThreadFactory threadFactory) : 创建一个单线程执行程序,它可安排在给定延迟后运行命令或者定期地执行。
接口 java.util.concurrent.ExecutorService
Future<T> submit(Callable<T> task) : 提交一个返回值的任务用于执行,返回一个表示任务的未决结果的 Future。
Future<?> submit(Runnable task) : 提交一个 Runnable 任务用于执行,并返回一个表示该任务的 Future。
<T> Future<T> submit(Runnable task, T result) : 提交一个 Runnable 任务用于执行,并返回一个表示该任务的 Future。result为返回的结果。
<T> T invokeAny(Collection<Callable<T>> tasks) : 执行给定的任务,如果某个任务已成功完成(也就是未抛出异常),则返回其结果。
<T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) : 执行给定的任务,如果在给定的超时期满前某个任务已成功完成(也就是未抛出异常),则返回其结果。
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) : 执行给定的任务,当所有任务完成时,返回保持任务状态和结果的 Future 列表。
<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) : 执行给定的任务,当所有任务完成或超时期满时(无论哪个首先发生),返回保持任务状态和结果的 Future 列表。
类 java.util.concurrent.ThreadPoolExecutor
int getLargestPoolSize() : 返回曾经同时位于池中的最大线程数。
类 java.util.concurrent.ScheduledThreadPoolExecutor
<V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) : 创建并执行在给定延迟后启用的 ScheduledFuture。
ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) : 创建并执行在给定延迟后启用的一次性操作。
ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) : 创建并执行一个在给定初始延迟后首次启用的定期操作,后续操作具有给定的周期;也就是将在 initialDelay 后开始执行,然后在 initialDelay+period 后执行,接着在 initialDelay + 2 * period 后执行,依此类推。
ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit) : 创建并执行一个在给定初始延迟后首次启用的定期操作,随后,在每一次执行终止和下一次执行开始之间都存在给定的延迟。
类 java.util.concurrent.ExecutorCompletionService
ExecutorCompletionService(Executor e) : 构建一个执行器完成服务来收集给定执行器的结果
Future<T> submit(Callable<T> task) : 提交一个任务给底层的执行器。
Future<T> submit(Runnable<T> task) : 提交一个任务给底层的执行器。
Future<T> task() : 获取并移除表示下一个已完成任务的 Future,如果目前不存在这样的任务,则等待。
Future<V> poll() : 获取并移除表示下一个已完成任务的 Future,如果不存在这样的任务,则返回 null。
Future<V> poll(long timeout, TimeUnit unit) : 获取并移除表示下一个已完成任务的 Future,如果目前不存在这样的任务,则将等待指定的时间(如果有必要)。
发表评论
-
(十)同步器
2011-11-14 23:32 1203java.util.concurrent包中包 ... -
(九) 执行器(线程池)
2011-11-14 22:39 1514线程池: 1.使用线程 ... -
(八)Callable与Future
2011-11-09 21:50 1103Callable是一个参数化的类型,只有一个方法call。 ... -
(七) 线程安全的集合
2011-11-04 22:58 2431如果多线程要并发的修 ... -
(六) 阻塞队列
2011-11-01 22:50 1449阻塞队列(BlockingQueue) ... -
(五) 同步
2011-10-26 22:27 1314多数实际的多线程应用中,两个或两个以上的线程需要共享同一数据 ... -
(四) 线程属性
2011-10-24 20:06 1178线程属性包括:线程优先级、守护线程、线程组和处理未捕获异常的处 ... -
(三) 线程状态
2011-10-24 20:05 9711.新生线程 当new一个 ... -
(二) 中断线程
2011-10-24 11:12 1117当线程的run()方法执行方法体中最后一句语句后,并经由执行r ... -
(一) 线程的概念
2011-10-22 12:19 817多线程 一. 线程的概念 多线程程序在较低的层次上 ...
相关推荐
重点回顾 练习问题 Introduction 2 多线程程序的评量标准 多线程程序的评量标准 安全性——不损坏对象 生存性——进行必要的处理 复用性——可再利用类 性能——能快速、大量进行处理 评量标准的总结 重点回顾 练习...
总结来说,《Win32多线程程序设计》不仅是一本介绍理论和技术的书籍,它还提供了大量实例和案例分析,帮助读者深入理解多线程程序设计的各个方面。对于那些希望开发高性能、响应迅速的应用程序,尤其是服务器端程序...
多线程基础理论, 多线程中常用API,多线程的实现方式, 线程池以及创建线程池相关API, 常见的设计模式等内容
Java多线程与并发编程是Java开发中不可或缺的一部分,它涉及到如何高效地利用CPU资源,实现并发执行多个任务。在操作系统层面,多线程是为了提高系统利用率,使得多个任务能够"同时"执行,但实际上,由于CPU的时钟...
《JAVA多线程设计模式》PDF 下载 《Java线程 高清晰中文第二版》中文第二版(PDF) 前言 第一章 线程简介 Java术语 线程概述 为什么要使用线程? 总结 第二章 Java线程API 通过Thread类创建线程 使用Runable接口...
总结来说,Win32多线程程序设计涉及到的关键知识点包括线程的创建与管理、同步机制、线程间的通信以及性能优化策略。通过深入学习和实践这些概念,开发者能够构建出更加高效、稳定且响应迅速的Windows应用程序。
下面我们将详细探讨OpenMP的核心概念、API以及如何在VS2005中使用OpenMP进行多线程编程。 1. **OpenMP的基本概念** - **并行区域(Parallel Region)**:OpenMP的核心是通过在代码中添加特定的pragma(预处理指令...
总结来说,基于MFC的多线程串口通信上位机项目,利用了C++和MFC的特性,结合Windows API进行串口操作,并通过多线程技术提高了通信效率和用户体验。在实际应用中,这样的上位机可以广泛应用于工业自动化、远程监控等...
总结,Win32多线程程序设计涵盖了许多复杂的概念和技术,包括线程创建、同步、通信、优先级管理、异常处理以及线程池等。理解并熟练掌握这些知识点,对于编写高效、可靠的多线程应用程序至关重要。《Win32多线程程序...
Java多线程是Java编程中的核心概念,它允许程序...通过理解和掌握以上知识点,开发者可以更好地设计和优化多线程程序,保证程序的正确性和高效性。对于更深入的源码分析和工具使用,可以参考提供的博文链接进行学习。
### POSIX多线程程序设计知识点概述 #### 一、引言 《POSIX多线程程序设计中文版》是一本专注于介绍POSIX环境下多线程编程技术的专业书籍。该书内容丰富,覆盖了多线程的基本概念、核心原理以及实际应用技巧等多个...
总结,Windows API 多线程编程是C++开发者掌握的一项重要技能,它使得程序能够更好地利用现代多核处理器的计算能力。通过学习和实践"Storm the Gates"这样的示例,我们可以更深入地理解线程的创建、同步和管理,从而...
#### 五、多线程设计模式 - **生产者消费者模型**:解决多线程之间的数据交换问题,通常涉及队列结构。 - **读写锁**:允许多个读线程同时访问共享资源,但不允许写操作与其他任何操作并发。 - **信号量**:用于...
本多线程编程指南主要针对iOS平台,特别是使用Swift语言的开发者。在现代iOS应用开发中,虽然有更新的技术如操作对象(Operation Objects)和Grand Central Dispatch(GCD)提供更高效和更现代的并发编程方式,但...
Java多线程编程是开发高并发应用的关键技术之一。它基于操作系统的多任务、多进程概念,通过线程实现程序内部的并发执行,以充分利用CPU资源。在Java中,线程是程序执行的最小单元,它们共享同一进程的内存空间,...
### VB 实现多线程详解 #### 一、引言 多线程编程技术在现代软件开发中扮演着至关重要的角色。...虽然VB在多线程支持方面不如一些现代语言那样完善,但通过合理的设计和使用API,仍然可以构建出高性能的应用程序。
2. **HBase客户端API**:HBase提供了Java客户端API,支持线程安全的`HTablePool`,这个池可以管理多个`HTable`实例,每个实例对应一个HBase表,允许多线程共享和复用这些实例,减少创建和销毁HTable对象的开销。...
总结来说,Win32多线程设计涉及到线程创建、调度、同步、通信、生命周期管理和线程局部存储等多个方面。掌握这些知识,开发者可以编写出高效、安全的多线程应用程序。在实际开发中,应根据需求选择合适的线程同步...
然而,需要注意的是,Visual Component Library(VCL)的大部分设计初衷并不包含多线程安全性的考虑。对于用户界面部分,VCL明确要求所有UI操作发生在主线程中,以保持界面的稳定性和一致性。而对于非用户界面部分,...