删掉过期的AsyncHandler
This commit is contained in:
@@ -1,97 +0,0 @@
|
|||||||
/*
|
|
||||||
* To change this license header, choose License Headers in Project Properties.
|
|
||||||
* To change this template file, choose Tools | Templates
|
|
||||||
* and open the template in the editor.
|
|
||||||
*/
|
|
||||||
package org.redkale.util;
|
|
||||||
|
|
||||||
import java.util.function.BiConsumer;
|
|
||||||
import java.nio.channels.CompletionHandler;
|
|
||||||
import java.util.function.*;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 异步回调函数
|
|
||||||
*
|
|
||||||
*
|
|
||||||
* <p>
|
|
||||||
* 详情见: https://redkale.org
|
|
||||||
*
|
|
||||||
* @deprecated 使用 java.nio.channels.CompletionHandler 代替
|
|
||||||
* @author zhangjx
|
|
||||||
* @param <V> 结果对象的泛型
|
|
||||||
* @param <A> 附件对象的泛型
|
|
||||||
*/
|
|
||||||
@Deprecated
|
|
||||||
public interface AsyncHandler<V, A> extends CompletionHandler<V, A> {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 创建 AsyncHandler 对象
|
|
||||||
*
|
|
||||||
* @param <V> 结果对象的泛型
|
|
||||||
* @param <A> 附件对象的泛型
|
|
||||||
* @param success 成功的回调函数
|
|
||||||
* @param fail 失败的回调函数
|
|
||||||
*
|
|
||||||
* @return AsyncHandler
|
|
||||||
*/
|
|
||||||
public static <V, A> AsyncHandler<V, A> create(final BiConsumer<V, A> success, final BiConsumer<Throwable, A> fail) {
|
|
||||||
return new AsyncHandler<V, A>() {
|
|
||||||
@Override
|
|
||||||
public void completed(V result, A attachment) {
|
|
||||||
if (success != null) success.accept(result, attachment);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void failed(Throwable exc, A attachment) {
|
|
||||||
if (fail != null) fail.accept(exc, attachment);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 创建没有返回结果的 AsyncHandler 对象
|
|
||||||
*
|
|
||||||
* @param <A> 附件对象的泛型
|
|
||||||
* @param success 成功的回调函数
|
|
||||||
* @param fail 失败的回调函数
|
|
||||||
*
|
|
||||||
* @return AsyncHandler
|
|
||||||
*/
|
|
||||||
public static <A> AsyncHandler<Void, A> create(final Consumer<A> success, final BiConsumer<Throwable, A> fail) {
|
|
||||||
return new AsyncHandler<Void, A>() {
|
|
||||||
@Override
|
|
||||||
public void completed(Void result, A attachment) {
|
|
||||||
if (success != null) success.accept(attachment);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void failed(Throwable exc, A attachment) {
|
|
||||||
if (fail != null) fail.accept(exc, attachment);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 创建没有附件对象的 AsyncNoResultHandler 对象
|
|
||||||
*
|
|
||||||
* @param <V> 结果对象的泛型
|
|
||||||
* @param success 成功的回调函数
|
|
||||||
* @param fail 失败的回调函数
|
|
||||||
*
|
|
||||||
* @return AsyncHandler
|
|
||||||
*/
|
|
||||||
public static <V> AsyncHandler<V, Void> create(final Consumer<V> success, final Consumer<Throwable> fail) {
|
|
||||||
return new AsyncHandler<V, Void>() {
|
|
||||||
@Override
|
|
||||||
public void completed(V result, Void attachment) {
|
|
||||||
if (success != null) success.accept(result);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void failed(Throwable exc, Void attachment) {
|
|
||||||
if (fail != null) fail.accept(exc);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@@ -98,11 +98,6 @@ public final class ObjectPool<T> implements Supplier<T>, Consumer<T> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Deprecated
|
|
||||||
public void offer(final T e) {
|
|
||||||
accept(e);
|
|
||||||
}
|
|
||||||
|
|
||||||
public long getCreatCount() {
|
public long getCreatCount() {
|
||||||
return creatCounter.longValue();
|
return creatCounter.longValue();
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user