标签:pre code 其他 ati 时间片 中断 同步 停止线程 read
??在Java多线程中,可以使用sleep()方法在指定毫秒数内让当前正在执行的线程休眠。
??下面这段代码,使得主函数的main线程休眠了2000ms,最后输出的间隔时间也是2000ms。
public class MyThread extends Thread {
public static void main(String[] args) {
try {
long begin;
long end;
begin = System.currentTimeMillis();
System.out.println("begin = " + begin);
Thread.sleep(2000);
end = System.currentTimeMillis();
System.out.println("end = " + end);
System.out.println("end - begin = " + (end - begin) + "ms");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
输出结果:
begin = 1486711105366
end = 1486711107366
end - begin = 2000ms
??虽然suspend和resume方法可以分别使得线程暂停和回复,但是这两个方法因为有缺点而已经被弃用。
缺点:
??可以使用yield方法进行暂停。
??yield()方法的作用是放弃当前的CPU资源,将它让给其他任务去占用CPU执行时间。但放弃的时间不确定,有可能刚刚放弃,马上又获得CPU时间片。
public class MyThread extends Thread {
@Override
public void run() {
long beginTime = System.currentTimeMillis();
int count = 0;
for (int i = 0; i < 50000000; i++) {
//Thread.yield();
count = count + (i + 1);
}
long endTime = System.currentTimeMillis();
System.out.println("用时: " + (endTime - beginTime) + "ms");
}
public static void main(String[] args) {
MyThread myThread = new MyThread();
myThread.start();
}
}
输出结果:
用时: 21ms
??去掉注释//Thread.yield()后。
输出结果:
用时: 4471ms
??从第二次输出可以看出,用时明显变长。
??虽然stop()可以停止一个线程,但是这个方法是不安全的,而且是已经被弃用作废的,最好不要使用它。
??interrupt()方法的使用效果并不像for+break语句那个,马上就停止循环。调用interrupt()方法仅仅是在当前线程中打了一个停止的标记,并不是真正停止线程。
public class MyThread extends Thread {
public static void main(String[] args) {
Thread.currentThread().interrupt();
System.out.println("是否停止1? " + Thread.interrupted());
System.out.println("是否停止2? " + Thread.interrupted());
System.out.println("end");
}
}
输出结果:
是否停止1? true
是否停止2? false
end
public class MyThread extends Thread {
@Override
public void run() {
for (int i = 0; i < 50000; i++) {
System.out.println(i);
}
}
public static void main(String[] args) {
try {
MyThread myThread = new MyThread();
myThread.start();
Thread.sleep(1000);
myThread.interrupt();
System.out.println("是否停止1? " + myThread.isInterrupted());
System.out.println("是否停止2? " + myThread.isInterrupted());
System.out.println("end");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
输出结果(末尾):
49997
49998
49999
是否停止1? false
是否停止2? false
end
??在run中加一个判断,如果停止了,则break跳出循环体。
public class MyThread extends Thread {
@Override
public void run() {
for (int i = 0; i < 50000000; i++) {
if (this.interrupted()) {
System.out.println("已经是停止状态了,我要退出了");
break;
}
System.out.println(i);
}
}
public static void main(String[] args) {
try {
MyThread myThread = new MyThread();
myThread.start();
Thread.sleep(1000);
myThread.interrupt();
System.out.println("end");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
输出结果(末尾):
160560
160561
160562
160563
160564
end
已经是停止状态了,我要退出了
??上述代码虽然可以停止线程,但是如果for的后面还有语句,那么还是会继续执行。
??因此可以用下述方法来解决。
public class MyThread extends Thread {
@Override
public void run() {
try {
for (int i = 0; i < 50000000; i++) {
if (this.interrupted()) {
System.out.println("已经是停止状态了,我要退出了");
throw new InterruptedException();
}
System.out.println(i);
}
System.out.println("for结束");
} catch (InterruptedException e) {
System.out.println("进入run中的catch了");
e.printStackTrace();
}
}
public static void main(String[] args) {
try {
MyThread myThread = new MyThread();
myThread.start();
Thread.sleep(1000);
myThread.interrupt();
System.out.println("end");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
输出结果(末尾):
152891
152892
152893
152894
end
已经是停止状态了,我要退出了
进入run中的catch了
java.lang.InterruptedException
at mythread.MyThread.run(MyThread.java:13)
标签:pre code 其他 ati 时间片 中断 同步 停止线程 read
原文地址:http://www.cnblogs.com/yangmingyu/p/6921277.html