以下是一个简单的示例代码,演示了如何使用Java的并发库来实现并发文件移动访问:
import java.io.File;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class ConcurrentFileMovement {
public static void main(String[] args) {
// 创建一个包含固定线程数的线程池
ExecutorService executorService = Executors.newFixedThreadPool(5);
// 遍历需要移动的文件夹
File sourceDir = new File("source_directory");
File[] files = sourceDir.listFiles();
if (files != null) {
for (File file : files) {
// 提交文件移动任务给线程池
executorService.submit(() -> moveFile(file, "destination_directory"));
}
}
// 关闭线程池
executorService.shutdown();
try {
// 等待所有任务完成
executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
private static void moveFile(File file, String destinationDirectory) {
// 获取文件名
String fileName = file.getName();
// 构造目标文件路径
File destinationFile = new File(destinationDirectory + File.separator + fileName);
try {
// 移动文件
file.renameTo(destinationFile);
System.out.println("Moved file: " + fileName + " to " + destinationDirectory);
} catch (Exception e) {
e.printStackTrace();
}
}
}
上述代码首先创建一个固定线程数的线程池,然后遍历源文件夹中的文件。对于每个文件,将移动任务提交给线程池进行处理。
在moveFile
方法中,首先获取文件名,然后构造目标文件的路径。然后,调用renameTo
方法将文件从源路径移动到目标路径。
最后,调用shutdown
方法关闭线程池,并使用awaitTermination
方法等待所有任务完成。
请注意,以上示例代码仅作为演示目的,实际应用中可能需要根据具体需求进行适当的修改和优化。
上一篇:并发文件夹遍历 Python
下一篇:并发问题的解决方案: