类的使用
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的子类 修饰符和类型 类 说明 class
AsyncIOThread
协议处理的IO线程类声明为WorkThread的org.redkale.net中的字段 修饰符和类型 字段 说明 protected WorkThread
Response. thread
返回WorkThread的org.redkale.net中的方法 修饰符和类型 方法 说明 static WorkThread
WorkThread. currentWorkThread()
当前WorkThread线程,不是WorkThread返回null -
org.redkale.net.client中WorkThread的使用
声明为WorkThread的org.redkale.net.client中的字段 修饰符和类型 字段 说明 protected WorkThread
ClientRequest. 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> void
AbstractDataSource. complete(WorkThread workThread, CompletableFuture<T> future, T value)
protected <T> void
AbstractDataSqlSource. complete(WorkThread workThread, CompletableFuture<T> future, T value)
protected <T> void
AbstractDataSource. completeExceptionally(WorkThread workThread, CompletableFuture<T> future, Throwable exp)
-