您的位置:首页 > 其它

Service使用方法 | AsyncTask的使用和原理 | 定时器触发线程

2011-05-21 10:54 591 查看

一、Service服务

      定义一个服务,需要扩展Service基类,重写onBind和onCreate方法。很多时候也要重写onStartCommand方法,当服务是通过startServiec而启动的,就会调用onStartCommand方法。

      服务是在应用程序的主线程上启动
,这意为着onStartCommand方法中完成的处理都是发生在GUI线程中。实现服务的标准模式是在onStartCommand中创建并运行一个新线程,用来在后台执行处理




 

二、后台线程AsyncTask异步任务

2.1.为什么要使用AsyncTask后台线程

因为AsyncTask提供了一种简单便捷的机制,可以将费时操作移入后台线程。它的组成包括两个部分:将在后台进行的处理,以及在处理完成后的UI更新。AsyncTask能帮助我们更便捷地使用UI线程,避免了使用threads 和 handlers带来的复杂性(实际上,它是对threads 和 handlers进行了封装,并实现了线程池的工作方式
)。

2.2.
三个参数/四个步骤

(1)子类实现应该按照以下格式,该泛型所带的三个参数
表示为:excute方法输入参数的类、报告进度的值、结果值
;

private

class

MyTask

extends

AsyncTask
<
Void
,

Void
,

Void
>

{

...

}

 

(2)子类应该实现以下事件处理程序:

1. onPreExecute(),

2. doInBackground(Params...),

3. onProgressUpdate(Progress...)

4. onPostExecute(Result)

//扩展Service基类
public class EarthquakeService extends Service {
public static final String NEW_EARTHQUAKE_FOUND = "New_Earthquake_Found";

private EarthquakeLookupTask lastLookup = null;
private Timer updateTimer;
private float minimumMagnitude;
// 扩展AsyncTask异步任务,
// doInBackground在后台线程运行,函数中处理耗时操作,例如获取网络数据等。
// onProgressUpdate在主线程运行,用来显示耗时操作的处理进度。
// onPostExecute在主线程运行,任务执行的方法通过此方法的参数返回。
private class EarthquakeLookupTask extends AsyncTask<Void, Quake, Void> {
@Override
protected Void doInBackground(Void... params) {
// 耗时操作......
}
@Override
protected void onProgressUpdate(Quake... values) {
super.onProgressUpdate(values);
}
@Override
protected void onPostExecute(Void result) {
super.onPostExecute(result);
}
}

// 当服务是通过startService启动时,就会调用onStartCommand方法
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
// ...

// 重启服务,在运行时终止服务的任意时刻,当重启服务时,会调用onStartCommand
// 因为该服务任务是启动一个AsyncTask任务(网络下载地震信息),用户每次点击刷新按钮
// 或者定时器每次触发时都会启动该服务。所以让其返回Service.START_STICKY,以表示其
// 重启特性。
return Service.START_STICKY;
};
// 每次触发定时器时,执行run操作
private TimerTask doRefresh = new TimerTask() {
public void run() {
refreshEarthquakes();
}
};
@Override
public void onCreate() {
updateTimer = new Timer("earthquakeUpdates");
}

@Override
public IBinder onBind(Intent intent) {
return null;
}
}


 


三、AsyncTask的原理

参考源码中的AsyncTask.java实现。

1.为什么使用线程池

AsyncTask类内部使用了线程池。

传统方法创建和销毁线程,对资源的耗费很大。线程池通过重用线程
来解决系统资源不足的问题,使应用程序相应更快,资源利用更合理。

 

2.JDK1.5中线程池的实现

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,
long keepAliveTime, TimeUnit unit,
BlockingQueue<Runnable> workQueue,
RejectedExecutionHandler handler)


corePoolSize: 线程池维护线程的最少数量

maximumPoolSize:线程池维护线程的最大数量

keepAliveTime: 线程池维护线程所允许的空闲时间

unit: 线程池维护线程所允许的空闲时间的单位

workQueue: 线程池所使用的缓冲队列

handler: 线程池对拒绝任务的处理策略

一个任务通过 execute(Runnable)方法被添加到线程池,任务就是一个 Runnable类型的对象,任务的执行方法就是 Runnable类型对象的run()方法。当一个任务通过execute(Runnable)方法欲添加到线程池时:

如果此时线程池中的数量小于corePoolSize,即使线程池中的线程都处于空闲状态,也要创建新的线程来处理被添加的任务。

如果此时线程池中的数量等于 corePoolSize,但是缓冲队列 workQueue未满,那么任务被放入缓冲队列。

如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量小于maximumPoolSize,建新的线程来处理被添加的任务。

如果此时线程池中的数量大于corePoolSize,缓冲队列workQueue满,并且线程池中的数量等于maximumPoolSize,那么通过 handler所指定的策略来处理此任务。

也就是:处理任务的优先级为:
核心线程corePoolSize、任务队列workQueue、最大线程maximumPoolSize,如果三者都满了,使用handler处理被拒绝的任务。

当线程池中的线程数量大于 corePoolSize时,如果某线程空闲时间超过keepAliveTime,线程将被终止。这样,线程池可以动态的调整池中的线程数。

四、定时器

 

参考
http://blog.csdn.net/robage/archive/2007/05/22/1620691.aspx
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息