当前位置：首页 > news >正文

Android 线程池

news 2025/8/29 12:16:12

在 Android 开发中，线程池是一种高效管理线程的方式，可以提高应用的性能和响应速度。使用线程池可以避免频繁创建和销毁线程带来的开销，并且可以更好地控制并发执行的任务数量。

Android 提供了 ThreadPoolExecutor 类来实现线程池，并且还提供了一些预定义的线程池工厂方法，如 Executors.newFixedThreadPool()、Executors.newCachedThreadPool() 和 Executors.newSingleThreadExecutor() 等。这些方法可以帮助你快速创建常用类型的线程池。

1. 常见的线程池类型

1.1 Fixed Thread Pool

固定大小的线程池，适用于需要限制并发线程数的场景。

int numberOfThreads = 5;
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(numberOfThreads);

1.2 Cached Thread Pool

可缓存的线程池，适用于执行大量短生命周期的任务。

ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

1.3 Single Thread Executor

单线程的线程池，适用于需要串行执行任务的场景。

ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

1.4 Scheduled Thread Pool

支持定时和周期性任务执行的线程池。

ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);

2. 创建自定义线程池

你可以通过 ThreadPoolExecutor 构造函数创建自定义线程池。

int corePoolSize = 5; // 核心线程数
int maximumPoolSize = 10; // 最大线程数
long keepAliveTime = 5000; // 线程空闲时间
TimeUnit unit = TimeUnit.MILLISECONDS; // 时间单位
BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(); // 工作队列ThreadPoolExecutor customThreadPool = new ThreadPoolExecutor(corePoolSize,maximumPoolSize,keepAliveTime,unit,workQueue
);

3. 使用线程池执行任务

你可以提交 Runnable 或 Callable 任务到线程池。

3.1 提交 Runnable 任务

fixedThreadPool.execute(new Runnable() {@Overridepublic void run() {// 执行任务System.out.println("Task executed by " + Thread.currentThread().getName());}
});

3.2 提交 Callable 任务

Callable 任务可以返回结果并且可以抛出异常。

Future<Integer> future = fixedThreadPool.submit(new Callable<Integer>() {@Overridepublic Integer call() throws Exception {// 执行任务并返回结果return 42;}
});try {int result = future.get(); // 获取任务结果System.out.println("Task result: " + result);
} catch (InterruptedException | ExecutionException e) {e.printStackTrace();
}

4. 关闭线程池

当你不再需要线程池时，应该关闭它以释放资源。

fixedThreadPool.shutdown(); // 平滑关闭，等待所有任务完成
// 或者
fixedThreadPool.shutdownNow(); // 强制关闭，尝试停止所有正在执行的任务

5. 示例代码

下面是一个完整的示例，展示了如何创建和使用线程池。

MainActivity.java

package com.example.threadpool;import androidx.appcompat.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;public class MainActivity extends AppCompatActivity {private static final String TAG = "MainActivity";@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);// 创建一个固定大小的线程池ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);// 提交多个 Runnable 任务for (int i = 0; i < 5; i++) {final int taskNumber = i;fixedThreadPool.execute(new Runnable() {@Overridepublic void run() {Log.d(TAG, "Running Task " + taskNumber + " on thread " + Thread.currentThread().getName());try {Thread.sleep(1000); // 模拟耗时操作} catch (InterruptedException e) {e.printStackTrace();}}});}// 提交一个 Callable 任务Future<String> future = fixedThreadPool.submit(new Callable<String>() {@Overridepublic String call() throws Exception {Log.d(TAG, "Running Callable Task on thread " + Thread.currentThread().getName());Thread.sleep(1500); // 模拟耗时操作return "Callable Task Result";}});// 获取 Callable 任务的结果try {String result = future.get();Log.d(TAG, "Callable Task Result: " + result);} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}// 关闭线程池fixedThreadPool.shutdown();}
}

activity_main.xml

<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"android:layout_width="match_parent"android:layout_height="match_parent"><TextViewandroid:id="@+id/textView"android:layout_width="wrap_content"android:layout_height="wrap_content"android:text="Check Logcat for Output"android:layout_centerInParent="true"/>
</RelativeLayout>