設為首頁|加入收藏

Android教程網 >> Android技術 >> Android開發 >> 關於android開發 >> Android應用開發教程之二十九（終結篇）：線程池的經典使用

Android應用開發教程之二十九（終結篇）：線程池的經典使用

編輯：關於android開發

　　由於經常會在網上或群裡看到有朋友會問線程方面的東西，就像我一個朋友他們老師講的，J2SE、J2EE裡面使用的線程方面的東西可能不是太多，但是在Android開發裡面，玩的就是線程（UI Thread）！好了，廢話就說這麼多吧，直入正題！今天要講的東西就是線程池、線程的高效率使用，靈活控制！今天死馬我就用最常用的幾種方式來分別實現應用中使用的線程方面的知識，（共寫了兩個不同入口的Activity來分開不同的實現方式，大家可以自行注釋AndroidManifest.xml中的Launch入口或打開注釋）好了，先隨便列幾個吧，如：AsyncTask 、Runnable 、Thread、ThreadPool、 Executors等等的使用，看我文章的朋友應該都很清楚我的方式啦，果斷先上效果，再一步步分解代碼，來吧，效果圖如下：

　　一：無大小限制的線程池執行效果如下

Android應用開發教程之二十九（終結篇）：線程池的經典使用

　　二：限制按順序來執行任務的線程池效果如下

Android應用開發教程之二十九（終結篇）：線程池的經典使用

　　三：一個一個任務的執行線程池效果如下（與按順序執行效果是一樣的，只是內部實現稍有不同）

Android應用開發教程之二十九（終結篇）：線程池的經典使用

　　四：按指定個數來執行任務的線程池效果如下

Android應用開發教程之二十九（終結篇）：線程池的經典使用

　　五：創建一個可在指定時間裡執行任務的線程池，亦可重復執行,不常用，效果與四相同

Android應用開發教程之二十九（終結篇）：線程池的經典使用

　　六：按指定工廠模式來執行的線程池，效果與四、五一樣，但用方式六創建的線程池都有在工廠中指定的線程屬性，

　　比如：線程名字、是否為用戶線程等等屬性

Android應用開發教程之二十九（終結篇）：線程池的經典使用

　　七：線程池中任務執行時可暫停效果圖如下

Android應用開發教程之二十九（終結篇）：線程池的經典使用

　　八：用Runnable、ConcurrentLinkedQueue、ConcurrentMap、Future、ExecutorService關聯實現的效果圖如下

Android應用開發教程之二十九（終結篇）：線程池的經典使用

　　哦的了，效果看完了，現在就請大家自行修改AndroidManifest.xml中主Activity的入口來看兩種不同方式實現的代碼效果吧，首先，先貼一下Main.java類的代碼，希望大家詳細看裡面的注釋，一定要詳細看，你不會吃虧的，相信我！（備注：為了寫文章加注釋還有查找的時候方便，把所有的主類及輔助類以內部類的形式寫到一個.java文件裡面了，如果朋友們覺得看著亂，不爽的話，可以自行將裡面的類抽取到單獨的.java文件中，幾分鐘搞定的事！）

　　方式一（純ExecutorService、AsyncTask、Runnable關聯實現相關文件如下）：

　　1.1：主類文件(Main.java)

Java代碼

/*
* FileName: Main.java
* CopyRight: Belong to <XiaoMaGuo Technologies > own
* Description: <description>
* Modify By : XiaoMaGuo ^_^
* Modify Date: 2013-10-15
* Follow Order No.: <Follow Order No.>
* Modify Order No.: <Modify Order No.>
* Modify Content: <modify content >
*/
package com.xiaoma.threadpooltest;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import android.annotation.TargetApi;
import android.app.Activity;
import android.content.Context;
import android.os.AsyncTask;
import android.os.Build;
import android.os.Bundle;
import android.os.SystemClock;
import android.util.AttributeSet;
import android.util.Log;
import android.view.LayoutInflater;
import android.view.View;
import android.view.ViewGroup;
import android.widget.AdapterView;
import android.widget.AdapterView.OnItemClickListener;
import android.widget.BaseAdapter;
import android.widget.LinearLayout;
import android.widget.ListView;
import android.widget.ProgressBar;
import android.widget.TextView;
import android.widget.Toast;
/**
* @TODO [The Class File Description]
* @author XiaoMaGuo ^_^
* @version [version-code, 2013-10-15]
* @since [Product/module]
*/
@TargetApi(Build.VERSION_CODES.HONEYCOMB)
public class Main extends Activity
{
private static int order = 0;
/** 總共多少任務（根據CPU個數決定創建活動線程的個數,這樣取的好處就是可以讓手機承受得住） */
// private static final int count = Runtime.getRuntime().availableProcessors() * 3 + 2;
/** 總共多少任務（我是在模擬器裡面跑的，為了效果明顯，所以寫死了為10個，如果在手機上的話，推薦使用上面的那個count） */
private static final int count = 10;
/** 每次只執行一個任務的線程池 */
private static ExecutorService singleTaskExecutor = null;
/** 每次執行限定個數個任務的線程池 */
private static ExecutorService limitedTaskExecutor = null;
/** 所有任務都一次性開始的線程池 */
private static ExecutorService allTaskExecutor = null;
/** 創建一個可在指定時間裡執行任務的線程池，亦可重復執行 */
private static ExecutorService scheduledTaskExecutor = null;
/** 創建一個可在指定時間裡執行任務的線程池，亦可重復執行（不同之處：使用工程模式） */
private static ExecutorService scheduledTaskFactoryExecutor = null;
private List<AsyncTaskTest> mTaskList = null;
/** 任務是否被取消 */
private boolean isCancled = false;
/** 是否點擊並取消任務標示符 */
private boolean isClick = false;
/** 線程工廠初始化方式一 */
ThreadFactory tf = Executors.defaultThreadFactory();
/** 線程工廠初始化方式二 */
private static class ThreadFactoryTest implements ThreadFactory
{
@Override
public Thread newThread(Runnable r)
{
Thread thread = new Thread(r);
thread.setName("XiaoMaGuo_ThreadFactory");
thread.setDaemon(true); // 將用戶線程變成守護線程,默認false
return thread;
}
}
static
{
singleTaskExecutor = Executors.newSingleThreadExecutor();// 每次只執行一個線程任務的線程池
limitedTaskExecutor = Executors.newFixedThreadPool(3);// 限制線程池大小為7的線程池
allTaskExecutor = Executors.newCachedThreadPool(); // 一個沒有限制最大線程數的線程池
scheduledTaskExecutor = Executors.newScheduledThreadPool(3);// 一個可以按指定時間可周期性的執行的線程池
scheduledTaskFactoryExecutor = Executors.newFixedThreadPool(3, new ThreadFactoryTest());// 按指定工廠模式來執行的線程池
scheduledTaskFactoryExecutor.submit(new Runnable()
{
@Override
public void run()
{
Log.i("KKK", "This is the ThreadFactory Test submit Run! ! ! ");
}
});
};
@Override
public void onCreate(Bundle icicle)
{
super.onCreate(icicle);
setContentView(R.layout.demo);
final ListView taskList = (ListView)findViewById(R.id.task_list);
taskList.setAdapter(new AsyncTaskAdapter(getApplication(), count));
taskList.setOnItemClickListener(new OnItemClickListener()
{
@Override
public void onItemClick(AdapterView<?> parent, View view, int position, long id)
{
if (position == 0) // 以第一項為例，來測試關閉線程池
{
/**
* 會關閉線程池方式一：但不接收新的Task,關閉後，正在等待執行的任務不受任何影響，會正常執行,無返回值!
*/
// allTaskExecutor.shutdown();
/**
* 會關閉線程池方式二：也不接收新的Task，並停止正等待執行的Task（也就是說，執行到一半的任務將正常執行下去），最終還會給你返回一個正在等待執行但線程池關閉卻沒有被執行的Task集合！
*/
List<Runnable> unExecRunn = allTaskExecutor.shutdownNow();
for (Runnable r : unExecRunn)
{
Log.i("KKK", "未執行的任務信息：=" + unExecRunn.toString());
}
Log.i("KKK", "Is shutdown ? = " + String.valueOf(allTaskExecutor.isShutdown()));
allTaskExecutor = null;
}
// 以第二項為例來測試是否取消執行的任務
AsyncTaskTest sat = mTaskList.get(1);
if (position == 1)
{
if (!isClick)
{
sat.cancel(true);
isCancled = true;
isClick = !isClick;
}
else
{
sat.cancel(false);
isCancled = false;
// isClick = false;
isClick = !isClick;
if (null != sat && sat.getStatus() == AsyncTask.Status.RUNNING)
{
if (sat.isCancelled())
{
sat = new AsyncTaskTest(sat.mTaskItem);
}
else
{
Toast.makeText(Main.this, "A task is already running, try later", Toast.LENGTH_SHORT)
.show();
}
}
/**
* 由於上面測試關閉，在不重新生成allTaskExecutor的同時，會報異常（沒有可以使用的線程池，故此處重新生成線程池對象）
*/
if (allTaskExecutor == null)
{
allTaskExecutor = Executors.newCachedThreadPool();
}
sat.executeOnExecutor(allTaskExecutor); // The task is already running(這也是個異常哦，小心使用！ )
}
}
else
{
sat.cancel(false);
isCancled = false;
// sat.execute(sat.mTaskItem);
// sat.executeOnExecutor(allTaskExecutor);
}
}
});
}
/**
* @TODO [ListView Item的條目適配器]
* @author XiaoMaGuo ^_^
* @version [version-code, 2013-10-22]
* @since [Product/module]
*/
private class AsyncTaskAdapter extends BaseAdapter
{
private Context mContext;
private LayoutInflater mFactory;
private int mTaskCount;
public AsyncTaskAdapter(Context context, int taskCount)
{
mContext = context;
mFactory = LayoutInflater.from(mContext);
mTaskCount = taskCount;
mTaskList = new ArrayList<AsyncTaskTest>(taskCount);
}
@Override
public int getCount()
{
return mTaskCount;
}
@Override
public Object getItem(int position)
{
return mTaskList.get(position);
}
@Override
public long getItemId(int position)
{
return position;
}
@Override
public View getView(int position, View convertView, ViewGroup parent)
{
if (convertView == null)
{
convertView = mFactory.inflate(R.layout.list_view_item, null);
AsyncTaskTest task = new AsyncTaskTest((MyListItem)convertView);
/**
* 下面兩種任務執行效果都一樣,形變質不變
* */
// task.execute();
// task.executeOnExecutor(AsyncTask.SERIAL_EXECUTOR);
/**
* 下面的方式在小於API 11級時效果是一樣的，但在高版本中的稍微有點不同,可以看以下AsyncTask核心變量的定義就知道了使用如下
* 方式時，系統會默認的采用五個一組，五個一組的方式來執行我們的任務，定義在：AsyncTask.class中，private static final int CORE_POOL_SIZE = 5;
* */
// use AsyncTask#THREAD_POOL_EXECUTOR is the same to older version #execute() (less than API 11)
// but different from newer version of #execute()
// task.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR);
/**
* 一個一個執行我們的任務,效果與按順序執行是一樣的(AsyncTask.SERIAL_EXECUTOR)
* */
// task.executeOnExecutor(singleTaskExecutor);
/**
* 按我們指定的個數來執行任務的線程池
* */
// task.executeOnExecutor(limitedTaskExecutor);
/**
* 不限定指定個數的線程池，也就是說：你往裡面放了幾個任務，他全部同一時間開始執行，不管你手機受得了受不了
* */
task.executeOnExecutor(allTaskExecutor);
/**
* 創建一個可在指定時間裡執行任務的線程池，亦可重復執行
* */
// task.executeOnExecutor(scheduledTaskExecutor);
/**
* 創建一個按指定工廠模式來執行任務的線程池,可能比較正規,但也不常用
*/
// task.executeOnExecutor(scheduledTaskFactoryExecutor);
mTaskList.add(task);
}
return convertView;
}
}
class AsyncTaskTest extends AsyncTask<Void, Integer, Void>
{
private MyListItem mTaskItem;
private String id;
private AsyncTaskTest(MyListItem item)
{
mTaskItem = item;
if (order < count || order == count)
{
id = "執行:" + String.valueOf(++order);
}
else
{
order = 0;
id = "執行:" + String.valueOf(++order);
}
}
@Override
protected void onPreExecute()
{
mTaskItem.setTitle(id);
}
/**
* Overriding methods
*/
@Override
protected void onCancelled()
{
super.onCancelled();
}
@Override
protected Void doInBackground(Void... params)
{
if (!isCancelled() && isCancled == false) // 這個地方很關鍵，如果不設置標志位的話，直接setCancel（true）是無效的
{
int prog = 0;
/**
* 下面的while中，寫了個分支用來做個假象（任務東西剛開始下載的時候，速度快，快下載完成的時候就突然間慢了下來的效果，大家可以想象一下，類似
* ：PP手機助手、91手機助手中或其它手機應用中，幾乎都有這個假象，開始快，結束時就下載變慢了，講白了就是開發的人不想讓你在下載到大於一半的時候，也就是快下載完的時候去點取消，你那樣得多浪費
* ！所以造個假象，讓你不想去取消而已）
*/
while (prog < 101)
{
if ((prog > 0 || prog == 0) && prog < 70) // 小於70%時，加快進度條更新
{
SystemClock.sleep(100);
}
else
// 大於70%時，減慢進度條更新
{
SystemClock.sleep(300);
}
publishProgress(prog); // 更新進度條
prog++;
}
}
return null;
}
@Override
protected void onPostExecute(Void result)
{
}
@Override
protected void onProgressUpdate(Integer... values)
{
mTaskItem.setProgress(values[0]); // 設置進度
}
}
}
/**
* @TODO [一個簡單的自定義 ListView Item]
* @author XiaoMaGuo ^_^
* @version [version-code, 2013-10-22]
* @since [Product/module]
*/
class MyListItem extends LinearLayout
{
private TextView mTitle;
private ProgressBar mProgress;
public MyListItem(Context context, AttributeSet attrs)
{
super(context, attrs);
}
public MyListItem(Context context)
{
super(context);
}
public void setTitle(String title)
{
if (mTitle == null)
{
mTitle = (TextView)findViewById(R.id.task_name);
}
mTitle.setText(title);
}
public void setProgress(int prog)
{
if (mProgress == null)
{
mProgress = (ProgressBar)findViewById(R.id.task_progress);
}
mProgress.setProgress(prog);
}
}

　　1.2：布局文件

XML/HTML代碼

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:paddingLeft="10dip"
android:paddingRight="10dip"
android:orientation="vertical" >
<ListView android:id="@+id/task_list"
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:divider="#cccccc"
android:dividerHeight="0.6dip"
android:footerDividersEnabled="true"
android:headerDividersEnabled="true" />
</LinearLayout>

　　方式二（Runnable、ConcurrentLinkedQueue、ConcurrentMap、Future、ExecutorService關聯實現的相關文件如下）：

　　2.1:主類文件(MyRunnableActivity.java)

Java代碼

　　2.2:輔助類（MyRunnable.java）

Java代碼

　　2.3:布局文件

XML/HTML代碼

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical" >
<LinearLayout
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:orientation="horizontal" >
<Button
android:id="@+id/button5"
android:layout_width="0dp"
android:layout_height="wrap_content"
android:layout_weight="1"
android:text="添加任務" />
<Button
android:id="@+id/button1"
android:layout_width="0dp"
android:layout_height="wrap_content"
android:layout_weight="1"
android:text="開始任務" />
<Button
android:id="@+id/button2"
android:layout_width="0dp"
android:layout_height="wrap_content"
android:layout_weight="1"
android:text="取消任務" />
<Button
android:id="@+id/button3"
android:layout_width="0dp"
android:layout_height="wrap_content"
android:layout_weight="1"
android:text="重新加載" />
<Button
android:id="@+id/button4"
android:layout_width="0dp"
android:layout_height="wrap_content"
android:layout_weight="1"
android:text="釋放資源" />
</LinearLayout>
<include layout="@layout/my_runnable_merge"/>
</LinearLayout>

　　方式一、方式二的全局配置文件AndroidManifest.xml文件的配置如下：

XML/HTML代碼

<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
package="com.xiaoma.threadpooltest"
android:versionCode="1"
android:versionName="1.0" >
<uses-sdk
android:minSdkVersion="8"
android:targetSdkVersion="15" />
<application
android:allowBackup="true"
android:icon="@drawable/ic_launcher"
android:label="@string/app_name"
android:theme="@style/AppTheme" >
<activity
android:name="Main"
android:label="@string/app_name" >
</activity>
<activity
android:name="MyRunnableActivity"
android:label="@string/app_name" >
<intent-filter>
<action android:name="android.intent.action.MAIN" />
<category android:name="android.intent.category.LAUNCHER" />
</intent-filter>
</activity>
</application>
</manifest>

　　好了，今天要寫內容，大體就是這些了，項目的源碼大家可以到這http://mzh3344258.blog.51cto.com/1823534/1313611 裡面的附件下載，WordPress裡面不知道怎麼上傳，大家多見諒吧，還得繞個路去下載，非常抱歉！ O_O 如果能仔細的將上面的東西都看完並消化的話，線程池方面的東西可能以後並不會太過為難你啦！呵呵，當然了，這些代碼中寫的都是一些比較簡單的寫法，僅僅是使用了在線程中休眠的方式來模擬網絡下載（還是個假象），如果在實際代碼中使用時，尤其在釋放資源這一塊，不要只是單單釋放了我們自己控制的線程池及其任務，還要將網絡請求的Http也一同銷毀(disconnection)掉哦，這樣才算做到了完美！如果還有哪位朋友沒有安卓源碼的話，可以到這個地址查看官方在線的安卓系統源碼：https://github.com/android 急急忙忙寫的，如果文章中有什麼地方寫的不對的，真的很希望Android老鳥、菜鳥都來指點、提問，代碼中若不對的，或不太合理的地方，有朋友發覺了還請及時批評指正！先在此謝謝大家啦！加油，每天進步一點，堅持總會有收獲的！廢話不多說了，大家晚安！…O_O…

關於android開發

開發入門初級開發中級開發高級開發關於android開發

相關文章

熱門文章

SwipeBackActivity 的使用，swipebackactivity android 拍照預覽，android拍照 Linux0.11內核--進程調度分析之1.初始化，linux0.11內核 Android--httpclient模擬post請求和get請求分析 Android應用開發Scroller詳解及源碼淺析 Android 常用 adb 命令，androidadb命令

android https正確調用方案（防中間人劫持），androidhttps

android https正確調用方案（防中間人劫持），androidh

手機影音6--視頻播放器的基本功能(3)，6--基本功能

手機影音6--視頻播放器的基本功能(3)，6--基本功能 1.自定義Vi

如何解決Linux系統中的Navicat for MySQL 1045錯誤

如何解決Linux系統中的Navicat for MySQL 1045錯

【開源】二維碼簽到手機andriod版下載！，開源簽到andriod

【開源】二維碼簽到手機andriod版下載！，開源簽到andriod&n

閱讀排行版

Copyright © Android教程網 All Rights Reserved