并行执行的Service,以媒体转码成新格式为例(并行执行的符号)

编辑：rootadmin

推荐整理分享并行执行的Service,以媒体转码成新格式为例(并行执行的符号)，希望有所帮助，仅作参考，欢迎阅读内容。

文章相关热门搜索词:并行执行的语言,并行执行的意思,并行执行的符号,并行执行的CPU利用率,并行执行的特征,并行执行的CPU利用率,并行执行的语言,并行执行的语言,内容如对您有帮助，希望把文章链接给更多的朋友！

大家众所周知，IntentService内置的handler只有一个线程，而AsyncTask又只适合时间至多几秒的操作，所以我们关注使用ExecutorService建立并行执行。为了确保Service一直保持活跃状态，需要调用Service.startForeground()方法。由于Service.startForeground()和Service.stopForeground()并不会叠加，所以还需要维护一个内部计数器，用来记录活跃的任务。一旦计数器为0则调用Service.stopForeground();

在这个例子中，主要介绍怎么利用Service执行并行的任务，并不是主要讲解多媒体&#;式文件转码的操作，所以转码操作都省略，主要实现并行执行。

public class MediaTranscoder extends Service {private static final int NOTIFICATION_ID = ;//定义通知的标识IDpublic static final String ACTION_TRANSCODE_MEDIA = "com.liyaunjinglyj.services.TRANSCODE_MEDIA";public static final String EXTRA_OUTPUT_TYPE = "outputType";//转码的类型private ExecutorService mExecutorService;//定义线程池private int mRunningJobs = 0;//任务计数器private final Object mLock = new Object();//锁private boolean mIsForeground = false;//标志是否需要结束Service@Overridepublic IBinder onBind(Intent intent) {return null;}@Overridepublic void onCreate() {super.onCreate();this.mExecutorService = Executors.newCachedThreadPool();//缓存型池子，先查看池中有没有以前建立的线程，如果有，就reuse.如果没有，就建一个新的线程加入池中,缓存型池子通常用于执行一些生存期很短的异步型任务,因此在一些面向连接的daemon型SERVER中用得不多。能reuse的线程，必须是timeout IDLE内的池中线程，缺省timeout是s,超过这个IDLE时长，线程实例将被终止及移出池。注意，放入CachedThreadPool的线程不必担心其结束，超过TIMEOUT不活动，其会自动被终止。}@Overridepublic int onStartCommand(Intent intent, int flags, int startId) {String action = intent.getAction();if (ACTION_TRANSCODE_MEDIA.equals(action)) {String outputType = intent.getStringExtra(EXTRA_OUTPUT_TYPE);

//启动新的作业增加计数器synchronized (mLock) {TranscodeRunnable transcodeRunnable = new TranscodeRunnable(intent.getData(), outputType);mExecutorService.execute(transcodeRunnable);//执行当前线程mRunningJobs&#;&#;;//线程计数器加1startForegroundIfNeeded();//创建通知，并保持活跃}}return START_NOT_STICKY;//系统回收资源关闭了当前的Service并不会重新启动.适合执行一次性操作。}@Overridepublic void onDestroy() {super.onDestroy();this.mExecutorService.shutdownNow();//shutdownNow() 方法阻止等待任务启动并试图停止当前正在执行的任务}private class TranscodeRunnable implements Runnable {private Uri mInData;private String mOutputType;private TranscodeRunnable(Uri inData, String outputType) {this.mInData = inData;this.mOutputType = outputType;}@Overridepublic void run() {

//在这里执行转码操作

//转码完成后，计数器加1

synchronized (mLock) {mRunningJobs--;stopForegroundIfAllDone();}}}private void stopForegroundIfAllDone() {if (mRunningJobs == 0 && mIsForeground) {stopForeground(true);this.mIsForeground = false;}}private void startForegroundIfNeeded() {if (!mIsForeground) {Notification notification = buildNotFication();startForeground(NOTIFICATION_ID, notification);this.mIsForeground = true;}}private Notification buildNotFication() {Notification notification = null;

//在这里构建通知return notification;}}

XMPP聊天软件客户端开发(1) 在此记下我做这个项目的过程，遇到的难点和问题。OK，项目开始问题当然是怎么去开发。在初步了解XMPP是一个协议就可以知道这个开源的协议会有很

利用 LeakCanary 来检查 Android 内存泄漏前言你被概率性的OOM困扰么？有时候，OOM像幽灵一样，挥之不去，可真想把它揪出来时，又捉之不着。或许，是时候用LeakCanary来诊断一下了。它是一个

Android核心基础-5.Android 数据存储与访问-4.ContentProvider 内容提供者续上一博文(Android核心基础-5.Android数据存储与访问-3.使用Sqlite进行数据存储)四、ContentProvider内容提供者4.1什么是ContentProviderContentProvider是安卓四大组件