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

增加了一个工具方法CheckedUtil,方便的执行会抛出受检查类型异常的方法调用或者代码段。该工具通过函数式的方式将那些需要抛出受检查异常的表达式或者代码段转化成一个标准的Func 对象。

Browse Source
This commit is contained in:
wangyao 2021-12-28 17:21:59 +08:00
parent d69a9b48df
commit affa4026c3
2 changed files with 117 additions and 136 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

235
hutool-core/src/main/java/cn/hutool/core/exceptions/CheckedUtil.java
View File

@ -1,12 +1,13 @@
package cn.hutool.core.exceptions; package cn.hutool.core.exceptions;
import cn.hutool.core.lang.func.*;
import java.util.Objects; import java.util.Objects;
import java.util.function.*;
/** /**
* 方便的执行会抛出受检查类型异常的方法调用或者代码段 * 方便的执行会抛出受检查类型异常的方法调用或者代码段
* <p> * <p>
* 该工具通过函数式的方式将那些需要抛出受检查异常的表达式或者代码段转化成一个标准的java8 functional 对象 * 该工具通过函数式的方式将那些需要抛出受检查异常的表达式或者代码段转化成一个 cn.hutool.core.lang.func.Func* 对象
* </p> * </p>
* *
* <pre> * <pre>
@ -24,13 +25,13 @@ import java.util.function.*;
* // use describedObject ... * // use describedObject ...
* *
* //上面的代码增加了异常块使得代码不那么流畅，现在可以这样写： * //上面的代码增加了异常块使得代码不那么流畅，现在可以这样写：
* Map<String, String> describedObject = CheckedUtil.uncheck(BeanUtils::describe).apply(new Object()); * Map<String, String> describedObject = CheckedUtil.uncheck(BeanUtils::describe).call(new Object());
* // use describedObject ... * // use describedObject ...
* *
* CheckedUtil.uncheck 方法接受任意可以转化成标准java8 函数式接口的 Lambda 表达式。返回对应的函数式对象。 * CheckedUtil.uncheck 方法接受任意可以转化成 cn.hutool.core.lang.func.Func* 函数式接口的 Lambda 表达式。返回对应的函数式对象。
* 上述代码可以理解为： * 上述代码可以理解为：
* Function<Object, Map<String, String>> aFunc = CheckedUtil.uncheck(BeanUtils::describe); * Func0<Object, Map<String, String>> aFunc = CheckedUtil.uncheck(BeanUtils::describe);
* Map<String, String> describedObject = aFunc.apply(传入参数); * Map<String, String> describedObject = aFunc.call(传入参数);
* 该aFunc对象代表的就是BeanUtils::describe这个表达式，且在内部转化了检查类型异常，不需要代码里面显示处理。 * 该aFunc对象代表的就是BeanUtils::describe这个表达式，且在内部转化了检查类型异常，不需要代码里面显示处理。
* *
* *
@ -41,101 +42,100 @@ import java.util.function.*;
public class CheckedUtil { public class CheckedUtil {
/** /**
* 接收一个可以转化成 java.util.function.Function的Lambda表达式，当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.Func 的Lambda表达式，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression Lambda表达式
* @param <T> 运行时传入的参数类型 * @param <P> 运行时传入的参数类型
* @param <R> 最终返回的数据类型 * @param <R> 最终返回的数据类型
* @return java.util.function.Function * @return cn.hutool.core.lang.func.Func
*/ */
public static <T, R> Function<T, R> uncheck(MorFunction<T, R> expression) { public static <P, R> FuncRt<P, R> uncheck(Func<P, R> expression) {
return uncheck(expression, new RuntimeException()); return uncheck(expression, new RuntimeException());
} }
/** /**
* 接收一个可以转化成 java.util.function.BiFunction的Lambda表达式当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.Func0 的Lambda表达式，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression 运行时传入的参数类型
* @param <T1> 运行时传入的参数类型一
* @param <T2> 运行时传入的参数类型二
* @param <R> 最终返回的数据类型 * @param <R> 最终返回的数据类型
* @return java.util.function.BiFunction * @return cn.hutool.core.lang.func.Func0
*/ */
public static <T1, T2, R> BiFunction<T1, T2, R> uncheck(BiFunction<T1, T2, R> expression) { public static <R> Func0Rt<R> uncheck(Func0<R> expression) {
return uncheck(expression, new RuntimeException()); return uncheck(expression, new RuntimeException());
} }
/** /**
* 接收一个可以转化成 java.util.function.Consumer的Lambda表达式，当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.Func1 的Lambda表达式，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression 运行时传入的参数类型
* @param <T> 运行时传入的参数类型 * @param <P> 运行时传入的参数类型
* @return java.util.function.Consumer * @param <R> 最终返回的数据类型
* @return cn.hutool.core.lang.func.Func1
*/ */
public static <T> Consumer<T> uncheck(MorConsumer<T> expression) { public static <P, R> Func1Rt<P, R> uncheck(Func1<P, R> expression) {
return uncheck(expression, new RuntimeException()); return uncheck(expression, new RuntimeException());
} }
/** /**
* 接收一个可以转化成 java.util.function.BiConsumer的Lambda表达式，当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.VoidFunc 的Lambda表达式，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression 运行时传入的参数类型
* @param <T> 运行时传入的参数类型一 * @param <P> 运行时传入的参数类型
* @param <U> 运行时传入的参数类型二 * @return cn.hutool.core.lang.func.VoidFunc
* @return java.util.function.BiConsumer
*/ */
public static <T, U> BiConsumer<T, U> uncheck(MorBiConsumer<T, U> expression) { public static <P> VoidFuncRt<P> uncheck(VoidFunc<P> expression) {
return uncheck(expression, new RuntimeException()); return uncheck(expression, new RuntimeException());
} }
/** /**
* 接收一个可以转化成 java.util.function.Runnable的Lambda表达式，当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.VoidFunc0 的Lambda表达式，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression 运行时传入的参数类型
* @return java.util.function.Runnable * @return cn.hutool.core.lang.func.VoidFunc0
*/ */
public static Runnable uncheck(MorRunnable expression) { public static VoidFunc0Rt uncheck(VoidFunc0 expression) {
return uncheck(expression, new RuntimeException()); return uncheck(expression, new RuntimeException());
} }
/** /**
* 接收一个可以转化成 java.util.function.Supplier的Lambda表达式，当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.VoidFunc1 的Lambda表达式，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression 运行时传入的参数类型
* @param <R> 运行时传入的参数类型 * @param <P> 运行时传入的参数类型
* @return java.util.function.Supplier * @return cn.hutool.core.lang.func.VoidFunc1
*/ */
public static <R> Supplier<R> uncheck(MorSupplier<R> expression) { public static <P> VoidFunc1Rt<P> uncheck(VoidFunc1<P> expression) {
return uncheck(expression, new RuntimeException()); return uncheck(expression, new RuntimeException());
} }
/** /**
* 接收一个可以转化成 java.util.function.Function的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.Func的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression Lambda表达式
* @param rte 期望抛出的运行时异常 * @param rte 期望抛出的运行时异常
* @param <T> 运行时传入的参数类型 * @param <P> 运行时传入的参数类型
* @param <R> 最终返回的数据类型 * @param <R> 最终返回的数据类型
* @return java.util.function.Function * @return cn.hutool.core.lang.func.Func
*/ */
public static <T, R> Function<T, R> uncheck(MorFunction<T, R> expression, RuntimeException rte) { public static <P, R> FuncRt<P, R> uncheck(Func<P, R> expression, RuntimeException rte) {
Objects.requireNonNull(expression, "expression can not be null"); Objects.requireNonNull(expression, "expression can not be null");
return t -> { return t -> {
try { try {
return expression.apply(t); return expression.call(t);
} catch (Throwable throwable) { } catch (Exception e) {
if (rte == null) { if (rte == null) {
throw new RuntimeException(throwable); throw new RuntimeException(e);
} else { } else {
rte.initCause(throwable); rte.initCause(e);
throw rte; throw rte;
} }
} }
@ -143,26 +143,24 @@ public class CheckedUtil {
} }
/** /**
* 接收一个可以转化成 java.util.function.BiFunction的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.Func0的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression Lambda表达式
* @param rte 期望抛出的运行时异常 * @param rte 期望抛出的运行时异常
* @param <T1> 运行时传入的参数类型一
* @param <T2> 运行时传入的参数类型二
* @param <R> 最终返回的数据类型 * @param <R> 最终返回的数据类型
* @return java.util.function.BiFunction * @return cn.hutool.core.lang.func.Func0
*/ */
public static <T1, T2, R> BiFunction<T1, T2, R> uncheck(BiFunction<T1, T2, R> expression, RuntimeException rte) { public static <R> Func0Rt<R> uncheck(Func0<R> expression, RuntimeException rte) {
Objects.requireNonNull(expression, "expression can not be null"); Objects.requireNonNull(expression, "expression can not be null");
return (t1, t2) -> { return () -> {
try { try {
return expression.apply(t1, t2); return expression.call();
} catch (Throwable throwable) { } catch (Exception e) {
if (rte == null) { if (rte == null) {
throw new RuntimeException(throwable); throw new RuntimeException(e);
} else { } else {
rte.initCause(throwable); rte.initCause(e);
throw rte; throw rte;
} }
} }
@ -170,24 +168,25 @@ public class CheckedUtil {
} }
/** /**
* 接收一个可以转化成 java.util.function.Consumer的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.Func1的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression Lambda表达式
* @param rte 期望抛出的运行时异常 * @param rte 期望抛出的运行时异常
* @param <T> 运行时传入的参数类型 * @param <P> 运行时传入的参数类型
* @return java.util.function.Consumer * @param <R> 最终返回的数据类型
* @return cn.hutool.core.lang.func.Func1
*/ */
public static <T> Consumer<T> uncheck(MorConsumer<T> expression, RuntimeException rte) { public static <P, R> Func1Rt<P, R> uncheck(Func1<P, R> expression, RuntimeException rte) {
Objects.requireNonNull(expression, "expression can not be null"); Objects.requireNonNull(expression, "expression can not be null");
return t -> { return t -> {
try { try {
expression.apply(t); return expression.call(t);
} catch (Throwable throwable) { } catch (Exception e) {
if (rte == null) { if (rte == null) {
throw new RuntimeException(throwable); throw new RuntimeException(e);
} else { } else {
rte.initCause(throwable); rte.initCause(e);
throw rte; throw rte;
} }
} }
@ -195,134 +194,104 @@ public class CheckedUtil {
} }
/** /**
* 接收一个可以转化成 java.util.function.BiConsumer的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.VoidFunc的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression Lambda表达式
* @param rte 期望抛出的运行时异常 * @param rte 期望抛出的运行时异常
* @param <T> 运行时传入的参数类型一 * @param <P> 运行时传入的参数类型
* @param <U> 运行时传入的参数类型二 * @return cn.hutool.core.lang.func.VoidFunc
* @return java.util.function.BiConsumer
*/ */
public static <T, U> BiConsumer<T, U> uncheck(MorBiConsumer<T, U> expression, RuntimeException rte) { public static <P> VoidFuncRt<P> uncheck(VoidFunc<P> expression, RuntimeException rte) {
Objects.requireNonNull(expression, "expression can not be null"); Objects.requireNonNull(expression, "expression can not be null");
return (t, u) -> { return t -> {
try { try {
expression.apply(t, u); expression.call(t);
} catch (Throwable throwable) { } catch (Exception e) {
if (rte == null) { if (rte == null) {
throw new RuntimeException(throwable); throw new RuntimeException(e);
} else { } else {
rte.initCause(throwable); rte.initCause(e);
throw rte; throw rte;
} }
} }
}; };
} }
/** /**
* 接收一个可以转化成 java.util.function.Runnable的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.VoidFunc0的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression Lambda表达式
* @param rte 期望抛出的运行时异常 * @param rte 期望抛出的运行时异常
* @return java.util.function.Runnable * @return cn.hutool.core.lang.func.VoidFunc0
*/ */
public static Runnable uncheck(MorRunnable expression, RuntimeException rte) { public static VoidFunc0Rt uncheck(VoidFunc0 expression, RuntimeException rte) {
Objects.requireNonNull(expression, "expression can not be null"); Objects.requireNonNull(expression, "expression can not be null");
return () -> { return () -> {
try { try {
expression.apply(); expression.call();
} catch (Throwable throwable) { } catch (Exception e) {
if (rte == null) { if (rte == null) {
throw new RuntimeException(throwable); throw new RuntimeException(e);
} else { } else {
rte.initCause(throwable); rte.initCause(e);
throw rte; throw rte;
} }
} }
}; };
} }
/** /**
* 接收一个可以转化成 java.util.function.Supplier的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常 * 接收一个可以转化成 cn.hutool.core.lang.func.VoidFunc1的Lambda表达式，和一个RuntimeException，当执行表达式抛出任何异常的时候，都会转化成运行时异常
* 如此一来，代码中就不用显示的try-catch转化成运行时异常 * 如此一来，代码中就不用显示的try-catch转化成运行时异常
* *
* @param expression Lambda表达式 * @param expression Lambda表达式
* @param rte 期望抛出的运行时异常 * @param rte 期望抛出的运行时异常
* @param <R> 运行时传入的参数类型 * @param <P> 运行时传入的参数类型
* @return java.util.function.Supplier * @return cn.hutool.core.lang.func.VoidFunc1
*/ */
public static <R> Supplier<R> uncheck(MorSupplier<R> expression, RuntimeException rte) { public static <P> VoidFunc1Rt<P> uncheck(VoidFunc1<P> expression, RuntimeException rte) {
Objects.requireNonNull(expression, "expression can not be null"); Objects.requireNonNull(expression, "expression can not be null");
return () -> { return t -> {
try { try {
return expression.apply(); expression.call(t);
} catch (Throwable throwable) { } catch (Exception e) {
if (rte == null) { if (rte == null) {
throw new RuntimeException(throwable); throw new RuntimeException(e);
} else { } else {
rte.initCause(throwable); rte.initCause(e);
throw rte; throw rte;
} }
} }
}; };
} }
public interface FuncRt<P, R> extends Func<P, R> {
/** R call(P... parameters) throws RuntimeException;
* 对应java8 java.util.function.Function ,能够接受受检查异常的转化
*
* @param <T>
* @param <R>
*/
public interface MorFunction<T, R> {
R apply(T t) throws Throwable;
} }
/** public interface Func0Rt<R> extends Func0<R> {
* 对应java8 java.util.function.BiFunction ,能够接受受检查异常的转化 R call() throws RuntimeException;
*
* @param <T1>
* @param <T2>
* @param <R>
*/
public interface MorBiFunction<T1, T2, R> {
R apply(T1 t1, T2 t2) throws Throwable;
} }
/** public interface Func1Rt<P, R> extends Func1<P, R> {
* 对应java8 java.util.function.Consumer ,能够接受受检查异常的转化 R call(P parameter) throws RuntimeException;
*
* @param <T>
*/
public interface MorConsumer<T> {
void apply(T t) throws Throwable;
} }
/** public interface VoidFuncRt<P> extends VoidFunc<P> {
* 对应java8 java.util.function.BiConsumer ,能够接受受检查异常的转化 void call(P... parameters) throws RuntimeException;
*
* @param <T>
* @param <U>
*/
public interface MorBiConsumer<T, U> {
void apply(T t, U u) throws Throwable;
} }
/** public interface VoidFunc0Rt extends VoidFunc0 {
* 对应java8 java.util.function.Runnable ,能够接受受检查异常的转化 void call() throws RuntimeException;
*/
public interface MorRunnable {
void apply() throws Throwable;
} }
/** public interface VoidFunc1Rt<P> extends VoidFunc1<P> {
* 对应java8 java.util.function.Supplier ,能够接受受检查异常的转化 void call(P parameter) throws RuntimeException;
*
* @param <R>
*/
public interface MorSupplier<R> {
R apply() throws Throwable;
} }
} }

18
hutool-core/src/test/java/cn/hutool/core/exceptions/CheckedUtilTest.java
View File

@ -1,5 +1,7 @@
package cn.hutool.core.exceptions; package cn.hutool.core.exceptions;
import cn.hutool.core.lang.func.Func1;
import cn.hutool.core.lang.func.VoidFunc0;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;
@ -17,12 +19,22 @@ import java.io.FileInputStream;
public class CheckedUtilTest { public class CheckedUtilTest {
@Test
public void sleepTest() {
VoidFunc0 func = () -> Thread.sleep(1000L);
func.callWithRuntimeException();
}
@Test @Test
public void supplierTest() { public void supplierTest() {
File noFile = new File("./no-file"); File noFile = new File("./no-file");
try { try {
//本行代码原本需要抛出受检查异常，现在只抛出运行时异常 //本行代码原本需要抛出受检查异常，现在只抛出运行时异常
FileInputStream stream = CheckedUtil.uncheck(() -> new FileInputStream(noFile)).get(); FileInputStream stream = CheckedUtil.uncheck(() -> new FileInputStream(noFile)).call();
} catch (Exception re) { } catch (Exception re) {
Assert.assertTrue(re instanceof RuntimeException); Assert.assertTrue(re instanceof RuntimeException);
} }
@ -31,7 +43,7 @@ public class CheckedUtilTest {
@Test @Test
public void functionTest() { public void functionTest() {
CheckedUtil.MorFunction<String, String> afunc = (funcParam) -> { Func1<String, String> afunc = (funcParam) -> {
if (funcParam.length() > 5) { if (funcParam.length() > 5) {
throw new Exception("这是受检查异常需要屌用处显示处理"); throw new Exception("这是受检查异常需要屌用处显示处理");
} }
@ -43,7 +55,7 @@ public class CheckedUtilTest {
try { try {
//本行代码原本需要抛出受检查异常，现在只抛出运行时异常 //本行代码原本需要抛出受检查异常，现在只抛出运行时异常
String reslut = CheckedUtil.uncheck(afunc).apply("hello world"); String reslut = CheckedUtil.uncheck(afunc).call("hello world");
} catch (Exception re) { } catch (Exception re) {
Assert.assertTrue(re instanceof RuntimeException); Assert.assertTrue(re instanceof RuntimeException);
} }