ehlxr/budd
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

update at 2020-12-21 22:59:45 by ehlxr

Browse Source
This commit is contained in:
ehlxr 2020-12-21 22:59:45 +08:00
parent 4ebea088a7
commit d4b44d2335
2 changed files with 132 additions and 58 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pom.xml
View File

@ -269,16 +269,16 @@
<artifactId>jodd-props</artifactId> <artifactId>jodd-props</artifactId>
<version>3.6.1</version> <version>3.6.1</version>
</dependency> </dependency>
<!-- <dependency>--> <!--<dependency>-->
<!-- <groupId>cn.ceres.did</groupId>--> <!-- <groupId>cn.ceres.did</groupId>-->
<!-- <artifactId>did-sdk</artifactId>--> <!-- <artifactId>did-sdk</artifactId>-->
<!-- <version>1.0-SNAPSHOT</version>--> <!-- <version>1.0-SNAPSHOT</version>-->
<!-- </dependency>--> <!--</dependency>-->
<!-- <dependency>--> <!--<dependency>-->
<!-- <groupId>cn.enncloud.ceres</groupId>--> <!-- <groupId>cn.enncloud.ceres</groupId>-->
<!-- <artifactId>ceres</artifactId>--> <!-- <artifactId>ceres</artifactId>-->
<!-- <version>1.1.0-SNAPSHOT</version>--> <!-- <version>1.1.0-SNAPSHOT</version>-->
<!-- </dependency>--> <!--</dependency>-->
<dependency> <dependency>
<groupId>org.jetbrains.kotlin</groupId> <groupId>org.jetbrains.kotlin</groupId>
<artifactId>kotlin-stdlib-jdk8</artifactId> <artifactId>kotlin-stdlib-jdk8</artifactId>
@ -321,6 +321,11 @@
<version>3.14.7</version> <version>3.14.7</version>
</dependency> </dependency>
<dependency>
<groupId>io.vavr</groupId>
<artifactId>vavr</artifactId>
<version>0.10.3</version>
</dependency>
</dependencies> </dependencies>
<build> <build>
<finalName>budd</finalName> <finalName>budd</finalName>

165
src/main/java/io/github/ehlxr/utils/Try.java
View File

@ -37,62 +37,78 @@ import java.util.function.Supplier;
* @author ehlxr * @author ehlxr
* @since 2020-12-03 10:37. * @since 2020-12-03 10:37.
*/ */
public class Try { public interface Try {
public static <T> Try.C<T> of(Consumer<? super T> consumer) { static <T> Try.C<T> of(Consumer<? super T> consumer) {
return new Try.C<>(consumer); return new Try.C<>(consumer);
} }
public static <R> Try.S<R> of(Supplier<? extends R> supplier) { static <R> Try.S<R> of(Supplier<? extends R> supplier) {
return new Try.S<>(supplier); return new Try.S<>(supplier);
} }
public static <T, R> Try.F<T, R> of(Function<? super T, ? extends R> function) { static <T, R> Try.F<T, R> of(Function<? super T, ? extends R> function) {
return new Try.F<>(function); return new Try.F<>(function);
} }
public static Try.V of(Void v) { static Try.V of(CheckedRunnable0 v) {
return new Try.V(v); return new Try.V(v);
} }
public static class V { class V {
private final Void v; private final CheckedRunnable0 checkedRunnable0;
private Consumer<? super Throwable> th; private Consumer<? super Throwable> throwableConsumer;
private CheckedRunnable1 finallyRunnable;
V(Void v) { V(CheckedRunnable0 checkedRunnable0) {
Objects.requireNonNull(v, "No value present"); Objects.requireNonNull(checkedRunnable0, "No checkedRunnable0 present");
this.v = v; this.checkedRunnable0 = checkedRunnable0;
} }
/** /**
* 计算结果 * 计算结果
*/ */
public void exec() { public void run() {
try { try {
v.exec(); checkedRunnable0.run();
} catch (Throwable e) { } catch (Throwable e) {
Optional.ofNullable(th).ifPresent(c -> c.accept(e)); Optional.ofNullable(throwableConsumer).ifPresent(c -> c.accept(e));
} finally {
Optional.ofNullable(finallyRunnable).ifPresent(CheckedRunnable1::run);
} }
} }
/** /**
* 如果有异常，调用自定义异常处理表达式 * 如果有异常，调用自定义异常处理表达式
* *
* @param th 自定义异常处理 lambda 表达式 * @param throwableConsumer 自定义异常处理 lambda 表达式
* @return {@link V} * @return {@link V}
*/ */
public V trap(Consumer<? super Throwable> th) { public V trap(Consumer<? super Throwable> throwableConsumer) {
Objects.requireNonNull(th, "No value present"); Objects.requireNonNull(throwableConsumer, "No throwableConsumer present");
this.th = th; this.throwableConsumer = throwableConsumer;
return this;
}
/**
* 自定义 finally 处理表达式
*
* @param finallyRunnable finally 处理 lambda 表达式
* @return {@link V}
*/
public V andFinally(CheckedRunnable1 finallyRunnable) {
Objects.requireNonNull(finallyRunnable, "No finallyRunnable present");
this.finallyRunnable = finallyRunnable;
return this; return this;
} }
} }
public static class C<T> { class C<T> {
private final Consumer<? super T> consumer; private final Consumer<? super T> consumer;
private Consumer<? super Throwable> th; private Consumer<? super Throwable> throwableConsumer;
private CheckedRunnable1 finallyRunnable;
C(Consumer<? super T> consumer) { C(Consumer<? super T> consumer) {
Objects.requireNonNull(consumer, "No value present"); Objects.requireNonNull(consumer, "No consumer present");
this.consumer = consumer; this.consumer = consumer;
} }
@ -105,29 +121,44 @@ public class Try {
try { try {
consumer.accept(t); consumer.accept(t);
} catch (Throwable e) { } catch (Throwable e) {
Optional.ofNullable(th).ifPresent(c -> c.accept(e)); Optional.ofNullable(throwableConsumer).ifPresent(c -> c.accept(e));
} finally {
Optional.ofNullable(finallyRunnable).ifPresent(CheckedRunnable1::run);
} }
} }
/** /**
* 如果有异常，调用自定义异常处理表达式 * 如果有异常，调用自定义异常处理表达式
* *
* @param th 自定义异常处理 lambda 表达式 * @param throwableConsumer 自定义异常处理 lambda 表达式
* @return {@link C} * @return {@link C}
*/ */
public C<T> trap(Consumer<? super Throwable> th) { public C<T> trap(Consumer<? super Throwable> throwableConsumer) {
Objects.requireNonNull(th, "No value present"); Objects.requireNonNull(throwableConsumer, "No throwableConsumer present");
this.th = th; this.throwableConsumer = throwableConsumer;
return this;
}
/**
* 自定义 finally 处理表达式
*
* @param finallyRunnable finally 处理 lambda 表达式
* @return {@link C}
*/
public C<T> andFinally(CheckedRunnable1 finallyRunnable) {
Objects.requireNonNull(finallyRunnable, "No finallyRunnable present");
this.finallyRunnable = finallyRunnable;
return this; return this;
} }
} }
public static class S<R> { class S<R> {
private final Supplier<? extends R> supplier; private final Supplier<? extends R> supplier;
private Consumer<? super Throwable> th; private Consumer<? super Throwable> throwableConsumer;
private CheckedRunnable1 finallyRunnable;
S(Supplier<? extends R> supplier) { S(Supplier<? extends R> supplier) {
Objects.requireNonNull(supplier, "No value present"); Objects.requireNonNull(supplier, "No supplier present");
this.supplier = supplier; this.supplier = supplier;
} }
@ -141,8 +172,10 @@ public class Try {
try { try {
return supplier.get(); return supplier.get();
} catch (Throwable e) { } catch (Throwable e) {
Optional.ofNullable(th).ifPresent(c -> c.accept(e)); Optional.ofNullable(throwableConsumer).ifPresent(c -> c.accept(e));
return r; return r;
} finally {
Optional.ofNullable(finallyRunnable).ifPresent(CheckedRunnable1::run);
} }
} }
@ -150,30 +183,45 @@ public class Try {
try { try {
return supplier.get(); return supplier.get();
} catch (Throwable e) { } catch (Throwable e) {
Optional.ofNullable(th).ifPresent(c -> c.accept(e)); Optional.ofNullable(throwableConsumer).ifPresent(c -> c.accept(e));
return null; return null;
} finally {
Optional.ofNullable(finallyRunnable).ifPresent(CheckedRunnable1::run);
} }
} }
/** /**
* 如果有异常，调用自定义异常处理表达式 * 如果有异常，调用自定义异常处理表达式
* *
* @param th 自定义异常处理 lambda 表达式 * @param throwableConsumer 自定义异常处理 lambda 表达式
* @return {@link S} * @return {@link S}
*/ */
public S<R> trap(Consumer<? super Throwable> th) { public S<R> trap(Consumer<? super Throwable> throwableConsumer) {
Objects.requireNonNull(th, "No value present"); Objects.requireNonNull(throwableConsumer, "No throwableConsumer present");
this.th = th; this.throwableConsumer = throwableConsumer;
return this;
}
/**
* 自定义 finally 处理表达式
*
* @param finallyRunnable finally 处理 lambda 表达式
* @return {@link S}
*/
public S<R> andFinally(CheckedRunnable1 finallyRunnable) {
Objects.requireNonNull(finallyRunnable, "No finallyRunnable present");
this.finallyRunnable = finallyRunnable;
return this; return this;
} }
} }
public static class F<T, R> { class F<T, R> {
private final Function<? super T, ? extends R> function; private final Function<? super T, ? extends R> function;
private Consumer<? super Throwable> th; private Consumer<? super Throwable> throwableConsumer;
private CheckedRunnable1 finallyRunnable;
F(Function<? super T, ? extends R> function) { F(Function<? super T, ? extends R> function) {
Objects.requireNonNull(function, "No value present"); Objects.requireNonNull(function, "No function present");
this.function = function; this.function = function;
} }
@ -188,8 +236,10 @@ public class Try {
try { try {
return function.apply(t); return function.apply(t);
} catch (Throwable e) { } catch (Throwable e) {
Optional.ofNullable(th).ifPresent(c -> c.accept(e)); Optional.ofNullable(throwableConsumer).ifPresent(c -> c.accept(e));
return r; return r;
} finally {
Optional.ofNullable(finallyRunnable).ifPresent(CheckedRunnable1::run);
} }
} }
@ -197,31 +247,50 @@ public class Try {
try { try {
return function.apply(t); return function.apply(t);
} catch (Throwable e) { } catch (Throwable e) {
Optional.ofNullable(th).ifPresent(c -> c.accept(e)); Optional.ofNullable(throwableConsumer).ifPresent(c -> c.accept(e));
return null; return null;
} finally {
Optional.ofNullable(finallyRunnable).ifPresent(CheckedRunnable1::run);
} }
} }
/** /**
* 如果有异常，调用自定义异常处理表达式 * 如果有异常，调用自定义异常处理表达式
* *
* @param th 自定义异常处理 lambda 表达式 * @param throwableConsumer 自定义异常处理 lambda 表达式
* @return {@link F} * @return {@link F}
*/ */
public F<T, R> trap(Consumer<? super Throwable> th) { public F<T, R> trap(Consumer<? super Throwable> throwableConsumer) {
Objects.requireNonNull(th, "No value present"); Objects.requireNonNull(throwableConsumer, "No throwableConsumer present");
this.th = th; this.throwableConsumer = throwableConsumer;
return this;
}
/**
* 自定义 finally 处理表达式
*
* @param finallyRunnable finally 处理 lambda 表达式
* @return {@link F}
*/
public F<T, R> andFinally(CheckedRunnable1 finallyRunnable) {
Objects.requireNonNull(finallyRunnable, "No finallyRunnable present");
this.finallyRunnable = finallyRunnable;
return this; return this;
} }
} }
@FunctionalInterface @FunctionalInterface
public interface Void { interface CheckedRunnable0 {
void exec() throws Throwable; void run() throws Throwable;
}
@FunctionalInterface
interface CheckedRunnable1 {
void run();
} }
@SuppressWarnings("ConstantConditions") @SuppressWarnings("ConstantConditions")
public static void main(String[] args) { static void main(String[] args) {
// 有返回值，无入参 // 有返回值，无入参
System.out.println(Try.of(() -> Long.valueOf("s")).trap(System.out::println).get(0L)); System.out.println(Try.of(() -> Long.valueOf("s")).trap(System.out::println).get(0L));
System.out.println(Try.of(() -> Long.valueOf("2w1")).get()); System.out.println(Try.of(() -> Long.valueOf("2w1")).get());
@ -232,7 +301,7 @@ public class Try {
ArrayList<String> list = null; ArrayList<String> list = null;
// 无返回值，无入参 // 无返回值，无入参
Try.of(() -> Thread.sleep(-1L)).exec(); Try.of(() -> Thread.sleep(-1L)).andFinally(() -> System.out.println("ddf")).trap(System.out::println).run();
// 无返回值，有入参 // 无返回值，有入参
Try.<String> Try.<String>