在处理大量数据时，例如计算一个字符串列表中的所有字符串对的相似度，多线程技术能够显著提升处理效率。然而，不恰当的多线程实现可能导致性能瓶颈，甚至引入错误。一个常见的误区是让每个线程独立地尝试处理整个数据集，这不仅导致任务重复，还可能因过度同步而使并行优势丧失。
低效的多线程方法解析
设想一个场景，我们有一个包含多个字符串的列表，需要计算其中每个字符串与其他所有字符串的相似度。如果采用一种简单粗暴的多线程方法，即创建多个线程，每个线程都尝试遍历并计算整个列表的相似度，会遇到以下问题：
- 任务重复： 每个线程都会执行相同的计算，导致大量重复工作，浪费计算资源。
- 同步开销： 如果为了避免数据不一致而使用synchronized块来保护共享资源（如结果列表或计数器），那么所有线程将按顺序进入同步块，实际上退化为串行执行，失去了多线程的并行优势。
- 复杂性： 管理每个线程的进度和避免重复计算的逻辑会变得复杂。
优化策略：基于任务拆分的ExecutorService
更高效且推荐的做法是将大的计算任务拆分为多个小的、独立的子任务，然后将这些子任务提交给一个线程池（ExecutorService）来执行。这种方法的核心思想是：
- 任务粒度化： 将“计算一个字符串与列表中所有其他字符串的相似度”定义为一个独立的任务。
- 线程池管理： ExecutorService负责线程的创建、管理和复用，避免了频繁创建和销毁线程的开销。
- 工作分配： 线程池中的线程会从任务队列中获取任务并执行，实现了任务的并行处理。
实现步骤与代码示例
以下是使用ExecutorService优化字符串相似度计算的详细步骤和代码示例：
立即学习“Java免费学习笔记（深入）”；
1. 定义独立的任务单元
首先，我们需要创建一个Runnable实现类，它代表了一个独立的相似度计算任务。这个任务将接收一个待比较的字符串以及整个字符串列表作为输入。
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
// 假设 solution 对象包含 findSimilarityRatio 方法
// 并且是线程安全的，或者在必要时进行同步
class Solution {
public double findSimilarityRatio(String s1, String s2) {
// 实际的字符串相似度计算逻辑
// 这里只是一个模拟，例如使用Jaro-Winkler、Levenshtein等算法
return (s1.length() + s2.length()) / 2.0; // 示例模拟
}
}
public class SimilarityCalculator {
// 假设 solution 是一个全局或静态可访问的实例
private static final Solution solution = new Solution();
/**
* 定义一个任务，用于计算单个字符串与列表中所有其他字符串的相似度。
*/
private static class SimilarityRunnable implements Runnable {
private final String targetStr; // 需要比较的字符串
private final List<String> stringList; // 整个字符串列表
public SimilarityRunnable(String targetStr, List<String> stringList) {
this.targetStr = targetStr;
this.stringList = stringList;
}
@Override
public void run() {
for (String listStr : stringList) {
// 避免自身与自身比较，通常相似度为1
// 注意：这里使用 == 比较的是引用，如果字符串是通过值相等但引用不同的方式创建，
// 则需要使用 .equals()。根据具体需求选择。
if (listStr == targetStr) {
continue;
}
// 如果 solution.findSimilarityRatio 方法不是线程安全的，
// 则需要在调用前进行同步，例如：
// synchronized (solution) {
// System.out.println(... solution.findSimilarityRatio(targetStr, listStr));
// }
// 但通常相似度计算函数应该是纯函数，不涉及共享状态，因此通常无需同步。
double similarity = solution.findSimilarityRatio(targetStr, listStr);
System.out.println(Thread.currentThread().getName()
+ ": 字符串 '" + targetStr + "' 与 '" + listStr + "' 的相似度是 "
+ String.format("%.2f", similarity));
}
}
}
// 模拟获取字符串列表的方法
static class ListExecutor {
public static List<String> getStringList() {
return List.of("apple", "aple", "apply", "banana", "bandana", "orange");
}
}
public static void main(String[] args) {
// 1. 创建一个固定大小的线程池，例如10个线程
ExecutorService pool = Executors.newFixedThreadPool(10);
// 2. 获取待处理的字符串列表
List<String> stringList = ListExecutor.getStringList();
// 3. 为列表中的每个字符串创建一个 SimilarityRunnable 任务并提交给线程池
for (String str : stringList) {
pool.submit(new SimilarityRunnable(str, stringList));
}
// 4. 关闭线程池：在所有任务提交完毕后，通知线程池不再接受新任务，并等待已提交任务完成
pool.shutdown();
// 可选：等待所有任务执行完毕，否则主线程可能在任务完成前退出
// try {
// pool.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
// } catch (InterruptedException e) {
// Thread.currentThread().interrupt();
// System.err.println("等待线程池终止时被中断: " + e.getMessage());
// }
System.out.println("所有相似度计算任务已提交。");
}
}代码说明：
- SimilarityRunnable 类： 实现了Runnable接口，其run方法包含了计算单个targetStr与stringList中所有其他字符串相似度的逻辑。
- ExecutorService pool = Executors.newFixedThreadPool(10);： 创建了一个包含10个线程的线程池。这意味着最多会有10个线程同时执行任务。
- for (String str : stringList) { pool.submit(new SimilarityRunnable(str, stringList)); }： 遍历原始字符串列表，为每个字符串创建一个SimilarityRunnable实例，并使用pool.submit()方法将其提交给线程池。submit方法会返回一个Future对象，如果任务有返回值的话。
- pool.shutdown();： 在所有任务都被提交后，必须调用shutdown()方法。这会阻止线程池接受新的任务，并允许已提交的任务执行完毕。一旦所有任务完成，线程池将最终终止。如果不调用shutdown()，程序可能会一直运行，因为线程池中的线程不会自动退出。
注意事项与最佳实践
- 任务粒度： 确保每个任务的粒度适中。如果任务太小，线程调度的开销可能会抵消并行带来的好处；如果任务太大，则可能无法充分利用多核CPU。在本例中，计算一个字符串与所有其他字符串的相似度是一个合适的任务粒度。
- 线程安全： 确保所有共享资源（例如存储计算结果的列表或solution对象）都是线程安全的。如果solution.findSimilarityRatio方法内部修改了共享状态，那么需要对其进行同步。但通常，相似度计算函数应该是纯函数，只接收输入并返回结果，不涉及副作用，因此通常是线程安全的。
- 资源管理： 务必在任务提交完毕后调用ExecutorService的shutdown()方法，以确保线程池能够正常关闭并释放资源。如果需要等待所有任务完成才能继续主线程的执行，可以使用pool.awaitTermination()方法。
- 异常处理： 在Runnable的run方法内部捕获并处理异常，否则未捕获的运行时异常可能会导致线程终止。
- 避免重复比较： 在SimilarityRunnable中，if (listStr == targetStr)用于跳过自身与自身的比较。请注意，==比较的是引用，如果字符串是通过不同的方式创建但内容相同，==会返回false。如果需要基于内容相等性跳过，应使用listStr.equals(targetStr)。
- 结果收集： 如果需要收集所有相似度计算的结果，可以考虑使用Callable接口配合Future对象，或者在Runnable内部将结果添加到线程安全的集合（如ConcurrentHashMap或CopyOnWriteArrayList）中。
总结
通过将复杂的计算任务拆分为独立的子任务，并利用Java的ExecutorService进行任务调度和执行，我们能够以高效且结构清晰的方式实现多线程并行处理。这种模式不仅避免了传统多线程实现中的任务重复和同步瓶颈，还简化了线程管理，是处理大规模数据并行计算的推荐方法。正确地应用ExecutorService能够显著提升应用程序的性能和响应能力。
