Java并发编程(二)
2016-03-12 14:55
337 查看
一、休眠(sleep)
影响任务行为的一种简单的方法是调用sleep(),这将使任务终止给定的时间。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class SleepingTask extends LiftOff{
public void run() {
while(countDown-->0){
System.out.println(status());
//thread.sleep(100);//旧方法
try {
TimeUnit.MILLISECONDS.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
System.err.println("Interrupt");
}
}
}
public static void main(String[] args) {
ExecutorService exec=Executors.newCachedThreadPool();
for (int i=0;i<5;i++){
exec.execute(new SleepingTask());
}
exec.shutdown();
}
}
二、优先级
线程的优先级将线程的重要性传递给了调度器,尽管CPU处理现有线程集的顺序是不确定的,但是调度器将倾向于让优先级最高的线程先执行。然后这并不意味着优先级较低的得不到执行。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class SleepingTask extends LiftOff{
public void run() {
while(countDown-->0){
System.out.println(status());
//thread.sleep(100);//旧方法
try {
TimeUnit.MILLISECONDS.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
System.err.println("Interrupt");
}
}
}
public static void main(String[] args) {
ExecutorService exec=Executors.newCachedThreadPool();
for (int i=0;i<5;i++){
exec.execute(new SleepingTask());
}
exec.shutdown();
}
}
影响任务行为的一种简单的方法是调用sleep(),这将使任务终止给定的时间。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class SleepingTask extends LiftOff{
public void run() {
while(countDown-->0){
System.out.println(status());
//thread.sleep(100);//旧方法
try {
TimeUnit.MILLISECONDS.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
System.err.println("Interrupt");
}
}
}
public static void main(String[] args) {
ExecutorService exec=Executors.newCachedThreadPool();
for (int i=0;i<5;i++){
exec.execute(new SleepingTask());
}
exec.shutdown();
}
}
二、优先级
线程的优先级将线程的重要性传递给了调度器,尽管CPU处理现有线程集的顺序是不确定的,但是调度器将倾向于让优先级最高的线程先执行。然后这并不意味着优先级较低的得不到执行。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class SleepingTask extends LiftOff{
public void run() {
while(countDown-->0){
System.out.println(status());
//thread.sleep(100);//旧方法
try {
TimeUnit.MILLISECONDS.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
System.err.println("Interrupt");
}
}
}
public static void main(String[] args) {
ExecutorService exec=Executors.newCachedThreadPool();
for (int i=0;i<5;i++){
exec.execute(new SleepingTask());
}
exec.shutdown();
}
}
相关文章推荐
- Java学习-序列化
- 访问javaweb服务器sessionid存放问题
- Java8新特性
- Eclipse 常用 快捷键
- 轻量级Java_EE企业应用实战-第5章Hibernate的基本用法-001
- [转]在 Eclipse 中嵌入 NASA World Wind Java SDK
- Java初始化及类的加载
- HBase Java API类介绍
- :通过Java Api与HBase交互(转)
- 使用spring4添加调度任务task的namespace
- Java序列化之Rebis存储序列化
- Java之美[从菜鸟到高手演变]之设计模式
- Zookeeper Api(java)入门与应用(转)
- Eclipse 下载 Git 仓库中代码(github上)
- 做一个合格的程序猿之浅析Spring IoC源码(十一)Spring refresh()方法解析之一
- Java注释规范整理
- java常用代码(不定时更新)
- Java读取操作word2003 word2007 word2010文档
- Java并发编程(一)
- Java反射