前言:如果这是一个非常愚蠢的错误或实际上有据可查的错误,我深表歉意。对我来说,现在这似乎很奇怪,完全没有意义。
应用程序
我在macOS 10.13.4上用IntelliJ IDEA Ultimate构建了一个Java命令行应用程序,该应用程序使用了下面列出的四个Maven库。其目的是从网站下载文件,并在这样做时浏览分页结果。
该应用程序的功能之一是能够保持循环运行,在完成当前扫描时是否经过了足够的时间,检查新结果。为此,它会调用Thread.sleep(remainingMillis)
作为 do-while 块中while
条件的一部分。
问题所在
该应用程序运行没有任何问题,但是在引入Thread.sleep()
调用后(我怀疑这是麻烦的行),发生了一些非常奇怪的行为:应用程序执行第一次运行没有问题,从配置的网站获取三个项目;然后配置为确保在再次运行之前已经过去了 60 秒。但是,在随后的运行中,日志指示它开始查看第 31 页(作为示例),而不是扫描结果的第一页,在那里它没有找到任何结果。没有找到任何东西,尝试三次中的两次查看第 32 页,最后一次尝试查看第 33 页;然后,它会再次等待,直到扫描迭代开始后经过 60 秒。
我无法确认这一点,但似乎它会在随后的扫描中继续这个计数:34、35、然后是 36,然后再次等待。但是,代码会建议当while
的另一个迭代启动时,这应该再次从 1 开始。
这可能是 IntelliJ 或 Java 在播放,它可能只需要清理 bin/obj 文件夹,但如果这是由于我的代码造成的,我宁愿知道它,这样我就不会遇到同样的愚蠢问题将来
。观察结果
几天后使用当前配置运行应用程序意味着它不会调用Thread.sleep()
,因为超过 60 秒过去了,因此它会立即继续下一次迭代; 发生这种情况时,奇怪的页面索引增量问题不会抬头 - 相反,下一次迭代从第 1 页继续,因为它应该。
之后,运行它以使它在开始下一次迭代之前Thread.sleep()
几秒钟也不会造成问题......很奇怪。这是梦吗?
《守则》
旁注:我添加了Thread.currentThread().interrupt()
来尝试解决此问题,但它似乎没有效果。
public static void main(String[] args) {
do {
startMillis = System.currentTimeMillis();
int itemsFetched = startFetching(agent, config, record, 1, 0);
} while (shouldRepeat(config.getRepeatSeconds(), startMillis));
}
private static boolean shouldRepeat(int repeatSeconds, long startMillis) {
long passedMillis = System.currentTimeMillis() - startMillis;
int repeatMillis = repeatSeconds * 1000;
boolean repeatSecondsReached = passedMillis >= repeatMillis;
if (repeatSeconds < 0) {
return false;
} else if (repeatSecondsReached) {
return true;
}
long remainingMillis = repeatMillis - passedMillis;
int remainingSeconds = (int) (remainingMillis / 1000);
try {
Thread.sleep(remainingMillis);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new RuntimeException(e);
}
return true;
}
private static int startFetching(Agenter agent, MyApplicationConfig config, MyApplicationRecord record, int pageIndex, int itemsFetched) {
String categoryCode = config.getCategoryCode();
List<Item> items = agent.getPageOfItems(categoryCode, pageIndex, config);
if (items == null) {
return itemsFetched;
}
int maxItems = config.getMaxItems();
try {
for (Item item : items) {
String itemURL = item.getURL();
agent.downloadItem(itemURL, config, item.getItemCount());
itemsFetched++;
if (maxItems > 0 && itemsFetched >= maxItems) {
return itemsFetched;
}
}
} catch (IOException e) {
// Log
}
return startFetching(agent, config, record, pageIndex + 1, itemsFetched);
}
}
马文图书馆
commons-cli:commons-cli:1.4
org.apache.logging.log4j:log4j-api:2.11.0
org.apache.logging.log4j:log4j-core:2.11.0
org.jsoup:jsoup:1.11.2
在调用 agent.getPageOfItems 提供了 pageIndex,但可以存储在实例变量或类似的东西中。错误本身可能是在其他调用中它可能没有重置(正确)。