您的位置:首页 > 其它

为什么要禁止在正式程序中使用sleep语句?

2011-05-19 16:27 211 查看
通常在以下两种情况中,开发人员会想到使用sleep()。

需要等一段时间然后去执行任务,比如定时任务等。

在无法获取实时信息的时候。举个例子而言,比如有一个线程,需要等待其他两个线程全部结束,才能够结束的时候,如果没有合适的方式,那么最容易想到的是是做一个for循环,加上sleep(),隔一段时间就去检查其他两个线程是否结束。

第二种情况和第一种情况看起来是类似的,总结起来貌似都是需要定时做一个任务,但是这两个有非常大的不同。前者是需求里面要求的,比如每天凌晨一点,去做某些信息的统计。而后者,实际上是因为错误的设计而产生出来的现象,这种错误设计的后果是,第一,无法实时获取结果;第二,对于程序的流程不能进行有效的控制,因为在任何情况下都无法预料会循环多长时间,会sleep多久,尤其是对于要进行取消操作的时候,无法预计返回的时间。

针对不同的情况,在实际使用中应该做如下处理。

1. 对于定时任务,我们通常有两种方式,实际使用中,首选第一种方式。

(1)在应用程序内部使用Timer。目前高级语言都已经封装了Timer的实现,所以,相关的代码一定不会出现sleep()字样。这种方式的优点在于,定时任务为应用自己控制,可以更灵活,也可以与应用结合的更紧密。

(2)使用操作系统的定时任务,即Linux的cronjob和windows系统的计划任务。这种方式的优点在于,由操作系统控制,即使应用处理故障,依然可以运行。

2. 对于错误设计引入的第二种情况,最常见的解决方式,是采用锁机制和通知机制(根本原理就是Event Driven)。比如在上文中提到的一个线程要等其他两个线程结束,那么可以考虑共享一个countdown的信号量,在每一个线程结束的时候,将信号量减一。通知机制通常需要在要执行的方法或者类里面,注册一个callback的方法,这样,在某个事件发生之后,就能够调用callback的函数,起到实时通知的作用。

所以,既然在常见的情况下可以选择更好或更正确的的方式来取代sleep(),那么在正式的程序中,严禁使用sleep()。

下面给出一个CountDown信号量的例子——让领导先走。(来源于我的同事xiaopeng,多谢他^_^。)

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class LatchDemo {
public static final int OFFICER_SIZE = 80;// 0000000;

public static final int COMMON_PEOPLE_SIZE = 20;

public static void main(String[] args) {
ExecutorService exeuctor = Executors.newCachedThreadPool();
// must share the single latch
CountDownLatch latch = new CountDownLatch(OFFICER_SIZE);
System.out.println("the building is fire!");

for (int i = 0; i < COMMON_PEOPLE_SIZE; i++) {
exeuctor.execute(new commonPeople(i, latch));
}

for (int i = 0; i < OFFICER_SIZE; i++) {
exeuctor.execute(new officer(i, latch));
}
exeuctor.shutdown();
}

static class officer implements Runnable {
private int id;

private CountDownLatch latch;

public officer(int id, CountDownLatch latch) {
this.id = id;
this.latch = latch;
}

@Override
public void run() {
goOut();
latch.countDown();
}

private void goOut() {
System.out.println("I must go firstly when fire! my id:" + id);
}
}

static class commonPeople implements Runnable {
private int id;

private CountDownLatch latch;

public commonPeople(int id, CountDownLatch latch) {
this.id = id;
this.latch = latch;
}

@Override
public void run() {
try {
latch.await();
goOut();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

private void goOut() {
System.out.println("I am common people! my id:" + id);
}
}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: 
相关文章推荐