类的使用
org.redkale.net.WorkThread
-
使用WorkThread的程序包 程序包 说明 org.redkale.net 网络TCP/UDP基础服务包org.redkale.net.client 客户端网络包org.redkale.source 数据源(数据库、缓存)操作包 -
-
org.redkale.net中WorkThread的使用
org.redkale.net中WorkThread的子类 修饰符和类型 类 说明 classAsyncIOThread协议处理的IO线程类声明为WorkThread的org.redkale.net中的字段 修饰符和类型 字段 说明 protected WorkThreadResponse. thread返回WorkThread的org.redkale.net中的方法 修饰符和类型 方法 说明 static WorkThreadWorkThread. currentWorkThread()当前WorkThread线程,不是WorkThread返回null -
org.redkale.net.client中WorkThread的使用
声明为WorkThread的org.redkale.net.client中的字段 修饰符和类型 字段 说明 protected WorkThreadClientRequest. workThread类型参数类型为WorkThread的org.redkale.net.client中的字段 修饰符和类型 字段 说明 protected BiFunction<WorkThread,String,Function<C,CompletableFuture<C>>>Client. authenticate参数类型为WorkThread的org.redkale.net.client中的方法 修饰符和类型 方法 说明 protected CompletableFuture<C>Client. connect(WorkThread workThread, SocketAddress addr)<T extends ClientRequest>
TClientRequest. workThread(WorkThread thread)类型变量类型为WorkThread的org.redkale.net.client中的构造器参数 构造器 说明 Client(String name, AsyncGroup group, boolean tcp, ClientAddress address, int maxConns, int maxPipelines, Supplier<R> pingRequestSupplier, Supplier<R> closeRequestSupplier, BiFunction<WorkThread,String,Function<C,CompletableFuture<C>>> authenticate)Client(String name, AsyncGroup group, boolean tcp, ClientAddress address, int maxConns, BiFunction<WorkThread,String,Function<C,CompletableFuture<C>>> authenticate)Client(String name, AsyncGroup group, boolean tcp, ClientAddress address, int maxConns, Supplier<R> closeRequestSupplier, BiFunction<WorkThread,String,Function<C,CompletableFuture<C>>> authenticate) -
org.redkale.source中WorkThread的使用
参数类型为WorkThread的org.redkale.source中的方法 修饰符和类型 方法 说明 protected <T> voidAbstractDataSource. complete(WorkThread workThread, CompletableFuture<T> future, T value)protected <T> voidAbstractDataSqlSource. complete(WorkThread workThread, CompletableFuture<T> future, T value)protected <T> voidAbstractDataSource. completeExceptionally(WorkThread workThread, CompletableFuture<T> future, Throwable exp)
-