fix:线程数改为8个

上级 80154ed9
...@@ -81,7 +81,7 @@ public class FileContainsUtil { ...@@ -81,7 +81,7 @@ public class FileContainsUtil {
private static void moreThread(List<List<String>> groupedPicNames, List<String> isNotExist) { private static void moreThread(List<List<String>> groupedPicNames, List<String> isNotExist) {
// 创建并启动4个线程来处理每个组的任务 // 创建并启动4个线程来处理每个组的任务
List<Thread> threads = new ArrayList<>(); List<Thread> threads = new ArrayList<>();
for (int i = 0; i < 6; i++) { for (int i = 0; i < 8; i++) {
final List<String> group = groupedPicNames.get(i); final List<String> group = groupedPicNames.get(i);
Thread thread = new Thread(() -> { Thread thread = new Thread(() -> {
// 在这里执行处理图片组的任务 // 在这里执行处理图片组的任务
...@@ -133,7 +133,7 @@ public class FileContainsUtil { ...@@ -133,7 +133,7 @@ public class FileContainsUtil {
* @return * @return
*/ */
private static List<List<String>> dataGroup(List<String> picNames) { private static List<List<String>> dataGroup(List<String> picNames) {
int groupSize = picNames.size() / 6; // 计算每组的大小 int groupSize = picNames.size() / 8; // 计算每组的大小
List<List<String>> groupedPicNames = List<List<String>> groupedPicNames =
picNames.stream() picNames.stream()
.collect(Collectors.groupingBy(e -> picNames.indexOf(e) / groupSize)) .collect(Collectors.groupingBy(e -> picNames.indexOf(e) / groupSize))
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册