From bf0466ef7657f3e91ad08d715a469b2d9ad64689 Mon Sep 17 00:00:00 2001 From: Looly Date: Fri, 29 Jan 2021 10:14:07 +0800 Subject: [PATCH] add method --- CHANGELOG.md | 2 + .../main/java/cn/hutool/core/img/ImgUtil.java | 22 +++++++-- .../cn/hutool/core/thread/ThreadUtil.java | 48 ++++++++++++++++++- .../cn/hutool/core/text/csv/CsvUtilTest.java | 27 +++++++++-- 4 files changed, 89 insertions(+), 10 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index fc1a1602a..7f659b057 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -21,6 +21,8 @@ * 【http 】 HttpServerRequest增加getParam方法 * 【http 】 RootAction增加可选name参数，返回指定文件名称 * 【db 】 支持人大金仓8的驱动识别 +* 【db 】 ThreadUtil增加createScheduledExecutor和schedule方法（issue#I2NUTC@Gitee） +* 【core 】 ImgUtil增加getImage方法（issue#I2DU1Z@Gitee） ### Bug修复 * 【core 】 修复FileUtil.move以及PathUtil.copy等无法自动创建父目录的问题（issue#I2CKTI@Gitee） diff --git a/hutool-core/src/main/java/cn/hutool/core/img/ImgUtil.java b/hutool-core/src/main/java/cn/hutool/core/img/ImgUtil.java index 98537bef7..9dcbfa410 100644 --- a/hutool-core/src/main/java/cn/hutool/core/img/ImgUtil.java +++ b/hutool-core/src/main/java/cn/hutool/core/img/ImgUtil.java @@ -29,6 +29,7 @@ import java.awt.Graphics2D; import java.awt.Image; import java.awt.Point; import java.awt.Rectangle; +import java.awt.Toolkit; import java.awt.font.FontRenderContext; import java.awt.geom.AffineTransform; import java.awt.geom.Rectangle2D; @@ -183,7 +184,7 @@ public class ImgUtil { * @param destImageFile 缩放后的图像地址 * @param width 缩放后的宽度 * @param height 缩放后的高度 - * @param fixedColor 补充的颜色，不补充为null + * @param fixedColor 补充的颜色，不补充为{@code null} * @throws IORuntimeException IO异常 */ public static void scale(File srcImageFile, File destImageFile, int width, int height, Color fixedColor) throws IORuntimeException { @@ -201,7 +202,7 @@ public class ImgUtil { * @param destStream 缩放后的图像目标流 * @param width 缩放后的宽度 * @param height 缩放后的高度 - * @param fixedColor 比例不对时补充的颜色，不补充为null + * @param fixedColor 比例不对时补充的颜色，不补充为{@code null} * @throws IORuntimeException IO异常 */ public static void scale(InputStream srcStream, OutputStream destStream, int width, int height, Color fixedColor) throws IORuntimeException { @@ -216,7 +217,7 @@ public class ImgUtil { * @param destStream 缩放后的图像目标流 * @param width 缩放后的宽度 * @param height 缩放后的高度 - * @param fixedColor 比例不对时补充的颜色，不补充为null + * @param fixedColor 比例不对时补充的颜色，不补充为{@code null} * @throws IORuntimeException IO异常 */ public static void scale(ImageInputStream srcStream, ImageOutputStream destStream, int width, int height, Color fixedColor) throws IORuntimeException { @@ -231,7 +232,7 @@ public class ImgUtil { * @param destImageStream 缩放后的图像目标流 * @param width 缩放后的宽度 * @param height 缩放后的高度 - * @param fixedColor 比例不对时补充的颜色，不补充为null + * @param fixedColor 比例不对时补充的颜色，不补充为{@code null} * @throws IORuntimeException IO异常 */ public static void scale(Image srcImage, ImageOutputStream destImageStream, int width, int height, Color fixedColor) throws IORuntimeException { @@ -245,7 +246,7 @@ public class ImgUtil { * @param srcImage 源图像 * @param width 缩放后的宽度 * @param height 缩放后的高度 - * @param fixedColor 比例不对时补充的颜色，不补充为null + * @param fixedColor 比例不对时补充的颜色，不补充为{@code null} * @return {@link Image} */ public static Image scale(Image srcImage, int width, int height, Color fixedColor) { @@ -1641,6 +1642,17 @@ public class ImgUtil { return result; } + /** + * 从URL中获取或读取图片对象 + * + * @param url URL + * @return {@link Image} + * @since 5.5.8 + */ + public static Image getImage(URL url){ + return Toolkit.getDefaultToolkit().getImage(url); + } + /** * 从{@link Resource}中读取图片 * diff --git a/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java b/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java index 09f9a382d..7dc251bdd 100644 --- a/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java +++ b/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java @@ -8,6 +8,7 @@ import java.util.concurrent.ExecutorCompletionService; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.LinkedBlockingQueue; +import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.ThreadFactory; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; @@ -31,7 +32,7 @@ public class ThreadUtil { * @param corePoolSize 同时执行的线程数大小 * @return ExecutorService */ - public static ExecutorService newExecutor(int corePoolSize) { + public static ExecutorService newExecutor(int corePoolSize) { ExecutorBuilder builder = ExecutorBuilder.create(); if (corePoolSize > 0) { builder.setCorePoolSize(corePoolSize); @@ -540,4 +541,49 @@ public class ThreadUtil { public static ConcurrencyTester concurrencyTest(int threadSize, Runnable runnable) { return (new ConcurrencyTester(threadSize)).test(runnable); } + + /** + * 创建{@link ScheduledThreadPoolExecutor} + * + * @param corePoolSize 初始线程池大小 + * @return {@link ScheduledThreadPoolExecutor} + * @since 5.5.8 + */ + public static ScheduledThreadPoolExecutor createScheduledExecutor(int corePoolSize) { + return new ScheduledThreadPoolExecutor(corePoolSize); + } + + /** + * 开始执行一个定时任务，执行方式分fixedRate模式和fixedDelay模式。 + * + * + * + * + * @param executor 定时任务线程池，{@code null}新建一个默认线程池 + * @param command 需要定时执行的逻辑 + * @param initialDelay 初始延迟 + * @param period 执行周期，单位毫秒 + * @param fixedRateOrFixedDelay {@code true}表示fixedRate模式，{@code false}表示fixedDelay模式 + * @return {@link ScheduledThreadPoolExecutor} + * @since 5.5.8 + */ + public static ScheduledThreadPoolExecutor schedule(ScheduledThreadPoolExecutor executor, + Runnable command, + long initialDelay, + long period, + boolean fixedRateOrFixedDelay){ + if(null == executor){ + executor = createScheduledExecutor(2); + } + if(fixedRateOrFixedDelay){ + executor.scheduleAtFixedRate(command, initialDelay, period, TimeUnit.NANOSECONDS); + } else{ + executor.scheduleWithFixedDelay(command, initialDelay, period, TimeUnit.NANOSECONDS); + } + + return executor; + } } diff --git a/hutool-core/src/test/java/cn/hutool/core/text/csv/CsvUtilTest.java b/hutool-core/src/test/java/cn/hutool/core/text/csv/CsvUtilTest.java index 87971852b..5de92c3fa 100644 --- a/hutool-core/src/test/java/cn/hutool/core/text/csv/CsvUtilTest.java +++ b/hutool-core/src/test/java/cn/hutool/core/text/csv/CsvUtilTest.java @@ -7,10 +7,11 @@ import org.junit.Assert; import org.junit.Ignore; import org.junit.Test; +import java.util.ArrayList; import java.util.List; public class CsvUtilTest { - + @Test public void readTest() { CsvReader reader = CsvUtil.getReader(); @@ -47,14 +48,14 @@ public class CsvUtilTest { CsvReader reader = CsvUtil.getReader(); reader.read(FileUtil.getUtf8Reader("test.csv"), Console::log); } - + @Test @Ignore public void writeTest() { CsvWriter writer = CsvUtil.getWriter("d:/test/testWrite.csv", CharsetUtil.CHARSET_UTF_8); writer.write( - new String[] {"a1", "b1", "c1", "123345346456745756756785656"}, - new String[] {"a2", "b2", "c2"}, + new String[] {"a1", "b1", "c1", "123345346456745756756785656"}, + new String[] {"a2", "b2", "c2"}, new String[] {"a3", "b3", "c3"} ); } @@ -68,4 +69,22 @@ public class CsvUtilTest { Console.log(row); } } + + @Test + @Ignore + public void writeWrapTest(){ + List> resultList=new ArrayList<>(); + List list =new ArrayList<>(); + list.add("\"name\""); + list.add("\"code\""); + resultList.add(list); + + list =new ArrayList<>(); + list.add("\"wang\""); + list.add(1); + resultList.add(list); + + final CsvWriter writer = CsvUtil.getWriter("d:/test/csvWrapTest.csv", CharsetUtil.CHARSET_UTF_8); + writer.write(resultList); + } }