ZhouXY108/hutool
1
0
Fork 0
mirror of https://gitee.com/chinabugotech/hutool.git synced 2025-04-19 03:01:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

修复Tailer指定初始读取行数的计算错误问题

Browse Source
This commit is contained in:
Looly 2024-06-21 20:32:34 +08:00
parent acb45d2a80
commit 75933bf214
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hutool-core/src/main/java/org/dromara/hutool/core/io/file/Tailer.java
View File

@ -80,7 +80,7 @@ public class Tailer implements Serializable {
* *
* @param file 文件 * @param file 文件
* @param lineHandler 行处理器 * @param lineHandler 行处理器
* @param initReadLine 启动时预读取的行数 * @param initReadLine 启动时预读取的行数，1表示一行
*/ */
public Tailer(final File file, final SerConsumer<String> lineHandler, final int initReadLine) { public Tailer(final File file, final SerConsumer<String> lineHandler, final int initReadLine) {
this(file, CharsetUtil.UTF_8, lineHandler, initReadLine, DateUnit.SECOND.getMillis()); this(file, CharsetUtil.UTF_8, lineHandler, initReadLine, DateUnit.SECOND.getMillis());
@ -103,7 +103,7 @@ public class Tailer implements Serializable {
* @param file 文件 * @param file 文件
* @param charset 编码 * @param charset 编码
* @param lineHandler 行处理器 * @param lineHandler 行处理器
* @param initReadLine 启动时预读取的行数 * @param initReadLine 启动时预读取的行数，1表示一行
* @param period 检查间隔 * @param period 检查间隔
*/ */
public Tailer(final File file, final Charset charset, final SerConsumer<String> lineHandler, final int initReadLine, final long period) { public Tailer(final File file, final Charset charset, final SerConsumer<String> lineHandler, final int initReadLine, final long period) {
@ -211,7 +211,9 @@ public class Tailer implements Serializable {
int currentLine = 0; int currentLine = 0;
while (nextEnd > start) { while (nextEnd > start) {
// 满 // 满
if (currentLine > initReadLine) { if (currentLine >= initReadLine) {
// issue#IA77ML initReadLine是行数，从1开始，currentLine是行号，从0开始
// 因此行号0表示一行，所以currentLine == initReadLine表示读取完毕
break; break;
} }