java - 下载多个文件时出现线程 IllegalThreadStateException

Question

我正在尝试多线程，并想实现一个小程序来同时下载多个文件。 我创建了一个扩展 Thread 的 FileDownloader 类。

总的来说，我的想法是创建一个包含所有相关 FileDownload 对象 (allDownloads) 的 ArrayList 和另一个名为 activeDownloads 的 ArrayList，我将活动下载的数量限制为 4。

程序下载了几个文件然后抛出这个异常。我知道在尝试再次启动线程时会抛出它。但是在下面的程序中，每次文件下载完成时，我都会中断一个线程并启动另一个线程，所以我不明白，我怎么会尝试启动 SAME Thread？

while (allDownloads.size() > 0) {
            while (activeDownloads.size() < 4) {
                if (allDownloads.iterator().hasNext()) {
                    FileDownloader d = allDownloads.iterator().next();
                    activeDownloads.add(d);
                    allDownloads.remove(d);

                }
            }
            for (int i = 0; i < activeDownloads.size(); i++) {
                FileDownloader t = activeDownloads.get(i);
                try {
                    if (!t.isRunning())
                        t.start();
                    else if (t.isFinished()) {
                        t.interrupt();
                        activeDownloads.remove(t);
                    }
                } catch (IllegalThreadStateException e) {
                    System.out.println("****Thread cannot be restarted****");
                }
            }

        }

感谢您的帮助

Answer 1

您的错误可能在这里：

if (allDownloads.iterator().hasNext()) {
    FileDownloader d = allDownloads.iterator().next();
    ...
}

您应该将 allDownloads.iterator() 的值保存在专用变量中，否则您将在每次调用时创建一个新的迭代器，然后始终获取第一个值，因此这里是同一个线程。

所以代码应该是：

Iterator<FileDownloader> it = allDownloads.iterator();
while (activeDownloads.size() < 4) {
    if (it.hasNext()) {
        FileDownloader d = it.next();
        activeDownloads.add(d);
        it.remove();

    }
}

Answer 2

您正在从 activeDownloads 中删除元素，同时对其进行迭代。尝试在 List 上向后迭代

for (int i = activeDownloads.size()-1 ; i >=0 ; i--) {...}

这样，当您从 List 中删除元素时，您的索引仍然是正确的