java使用线程下载多个文件

我正在尝试使用线程下载与模式匹配的多个文件。 该模式可以匹配1或5或10个差异大小的文件。

为简单起见，我们可以说下载文件的实际代码是downloadFile（）方法，而fileNames是与模式匹配的文件名列表。 我如何使用线程执行此操作。 每个线程只下载一个文件。 是否可以在for循环中创建一个新线程。

for (String name : fileNames){ downloadFile(name, toPath); } 

Answer 1

你真的想要使用ExecutorService而不是单独的线程，它更干净，可能性能更高，并且可以让你以后更容易地改变事物（线程数，线程名称等）：

 ExecutorService pool = Executors.newFixedThreadPool(10); for (String name : fileNames) { pool.submit(new DownloadTask(name, toPath)); } pool.shutdown(); pool.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS); // all tasks have now finished (unless an exception is thrown above) 

在你class级的其他地方定义实际工作马DownloadTask ：

 private static class DownloadTask implements Runnable { private String name; private final String toPath; public DownloadTask(String name, String toPath) { this.name = name; this.toPath = toPath; } @Override public void run() { // surround with try-catch if downloadFile() throws something downloadFile(name, toPath); } } 

shutdown()方法具有非常混乱的名称，因为它“将允许先前提交的任务在终止之前执行”。 awaitTermination()声明您需要处理的InterruptedException 。

Answer 2

是的，你当然可以在for循环中创建一个新线程。 像这样的东西：

 List threads = new ArrayList(); for (String name : fileNames) { Thread t = new Thread() { @Override public void run() { downloadFile(name, toPath); } }; t.start(); threads.add(t); } for (Thread t : threads) { t.join(); } // Now all files are downloaded. 

您还应该考虑在Executors.newFixedThreadPool(int)创建的线程池中使用Executors.newFixedThreadPool(int) 。

Answer 3

是的，您可以创建内联线程。

 for (final String name : fileNames){ new Thread() { public void run() { downloadFile(name, toPath); } }.start(); } 

Answer 4

使用Executor ，试试这个。

 ExecutorService exec= Executors.newCachedThreadPool() for (String name : fileNames){ exec.submit(new Runnable() { public void run() { downloadFile(name, toPath); } }); } 

如果你想同时说三个下载运行，你可以使用：

 Executors.newFixedThreadPool(3) 

Answer 5

所有上面提到的方法都创建了Threads但实际的Concurreny却没有实现。

 ExecutorService pool = Executors.newFixedThreadPool(5); final File folder = new File("YOUR_FILES_PATH"); int l = folder.listFiles().length; System.out.println("Total Files----"+folder.listFiles().length); long timeStartFuture = Calendar.getInstance().getTimeInMillis(); pool.execute(new DownloadFile(folder,0,l/2)); pool.execute(new DownloadFile(folder,(l/2),l)); pool.shutdown(); try { pool.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } long timeEndFuture = Calendar.getInstance().getTimeInMillis(); long timeNeededFuture = timeEndFuture - timeStartFuture; System.out.println("Parallel calculated in " + timeNeededFuture + " ms"); 

以上程序用于实现concurreny，请根据您的要求进行修改。