ZhouXY108/hutool
1
0
Fork 0
mirror of https://gitee.com/chinabugotech/hutool.git synced 2025-05-09 23:51:34 +08:00
Code Issues Packages Projects Releases Wiki Activity

add stop for Tailer

Browse Source
This commit is contained in:
Looly 2021-05-08 08:23:33 +08:00
parent 5697b4b7b0
commit 7c866e10e0
2 changed files with 18 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGELOG.md
View File

@ -11,6 +11,7 @@
* 【extra 】 Ftp的remoteVerificationEnabled改为false（issue#I3OSA2@Gitee） * 【extra 】 Ftp的remoteVerificationEnabled改为false（issue#I3OSA2@Gitee）
### 🐞Bug修复 ### 🐞Bug修复
* 【core 】 修复createScheduledExecutor单位不是毫秒的问题（issue#I3OYIW@Gitee） * 【core 】 修复createScheduledExecutor单位不是毫秒的问题（issue#I3OYIW@Gitee）
* 【core 】 修复Tailer无stop问题（issue#I3PQLQ@Gitee）
------------------------------------------------------------------------------------------------------------- -------------------------------------------------------------------------------------------------------------

26
hutool-core/src/main/java/cn/hutool/core/io/file/Tailer.java
View File

@ -23,7 +23,7 @@ import java.util.concurrent.TimeUnit;
/** /**
* 文件内容跟随器，实现类似Linux下"tail -f"命令功能 * 文件内容跟随器，实现类似Linux下"tail -f"命令功能
* *
* @author looly * @author looly
* @since 4.5.2 * @since 4.5.2
*/ */
@ -46,7 +46,7 @@ public class Tailer implements Serializable {
/** /**
* 构造，默认UTF-8编码 * 构造，默认UTF-8编码
* *
* @param file 文件 * @param file 文件
* @param lineHandler 行处理器 * @param lineHandler 行处理器
*/ */
@ -56,7 +56,7 @@ public class Tailer implements Serializable {
/** /**
* 构造，默认UTF-8编码 * 构造，默认UTF-8编码
* *
* @param file 文件 * @param file 文件
* @param lineHandler 行处理器 * @param lineHandler 行处理器
* @param initReadLine 启动时预读取的行数 * @param initReadLine 启动时预读取的行数
@ -67,7 +67,7 @@ public class Tailer implements Serializable {
/** /**
* 构造 * 构造
* *
* @param file 文件 * @param file 文件
* @param charset 编码 * @param charset 编码
* @param lineHandler 行处理器 * @param lineHandler 行处理器
@ -78,7 +78,7 @@ public class Tailer implements Serializable {
/** /**
* 构造 * 构造
* *
* @param file 文件 * @param file 文件
* @param charset 编码 * @param charset 编码
* @param lineHandler 行处理器 * @param lineHandler 行处理器
@ -104,7 +104,7 @@ public class Tailer implements Serializable {
/** /**
* 开始监听 * 开始监听
* *
* @param async 是否异步执行 * @param async 是否异步执行
*/ */
public void start(boolean async) { public void start(boolean async) {
@ -133,10 +133,17 @@ public class Tailer implements Serializable {
} }
} }
/**
* 结束，此方法需在异步模式或
*/
public void stop(){
this.executorService.shutdown();
}
// ---------------------------------------------------------------------------------------- Private method start // ---------------------------------------------------------------------------------------- Private method start
/** /**
* 预读取行 * 预读取行
* *
* @throws IOException IO异常 * @throws IOException IO异常
*/ */
private void readTail() throws IOException { private void readTail() throws IOException {
@ -195,7 +202,7 @@ public class Tailer implements Serializable {
/** /**
* 检查文件有效性 * 检查文件有效性
* *
* @param file 文件 * @param file 文件
*/ */
private static void checkFile(File file) { private static void checkFile(File file) {
@ -210,7 +217,7 @@ public class Tailer implements Serializable {
/** /**
* 命令行打印的行处理器 * 命令行打印的行处理器
* *
* @author looly * @author looly
* @since 4.5.2 * @since 4.5.2
*/ */
@ -220,4 +227,5 @@ public class Tailer implements Serializable {
Console.log(line); Console.log(line);
} }
} }
} }