模块 org.redkale

程序包 org.redkale.util

类 ThreadHashExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

org.redkale.util.ThreadHashExecutor

所有已实现的接口:

Executor, ExecutorService

@Deprecated(since="2.8.0")
public class ThreadHashExecutor
extends AbstractExecutorService

已过时。

线程池

详情见: https://redkale.org

从以下版本开始:

2.1.0

作者:

zhangjx

构造器概要

构造器

构造器	说明
ThreadHashExecutor()	已过时。
ThreadHashExecutor(int size)	已过时。
ThreadHashExecutor(int size, ThreadFactory factory)	已过时。

方法概要

修饰符和类型	方法	说明
boolean	awaitTermination(long l, TimeUnit tu)	已过时。
void	execute(int hash, Runnable command)	已过时。
void	execute(Serializable hash, Runnable command)	已过时。
void	execute(Runnable command)	已过时。
int	getCorePoolSize()	已过时。
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)	已过时。
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)	已过时。
<T> T	invokeAny(Collection<? extends Callable<T>> tasks)	已过时。
<T> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)	已过时。
boolean	isShutdown()	已过时。
boolean	isTerminated()	已过时。
void	setThreadFactory(ThreadFactory factory)	已过时。
void	shutdown()	已过时。
List<Runnable>	shutdownNow()	已过时。
Future	submit(int hash, Runnable task)	已过时。
<T> Future<T>	submit(int hash, Runnable task, T result)	已过时。
<T> Future<T>	submit(int hash, Callable<T> task)	已过时。
Future	submit(Runnable task)	已过时。
<T> Future<T>	submit(Runnable task, T result)	已过时。
<T> Future<T>	submit(Callable<T> task)	已过时。
int	waitingSize()	已过时。

从类继承的方法 java.util.concurrent.AbstractExecutorService

newTaskFor, newTaskFor

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ThreadHashExecutor

public ThreadHashExecutor()

已过时。

ThreadHashExecutor

public ThreadHashExecutor(int size)

已过时。

ThreadHashExecutor

public ThreadHashExecutor(int size,
                          ThreadFactory factory)

已过时。

方法详细资料

setThreadFactory

public void setThreadFactory(ThreadFactory factory)

已过时。

getCorePoolSize

public int getCorePoolSize()

已过时。

execute

public void execute(Runnable command)

已过时。

execute

public void execute(int hash,
                    Runnable command)

已过时。

execute

public void execute(Serializable hash,
                    Runnable command)

已过时。

submit

public Future submit(Runnable task)

已过时。

指定者:

submit 在接口中 ExecutorService

覆盖:

submit 在类中 AbstractExecutorService

submit

public Future submit(int hash,
                     Runnable task)

已过时。

submit

public <T> Future<T> submit(Runnable task,
                            T result)

已过时。

指定者:

submit 在接口中 ExecutorService

覆盖:

submit 在类中 AbstractExecutorService

submit

public <T> Future<T> submit(int hash,
                            Runnable task,
                            T result)

已过时。

submit

public <T> Future<T> submit(Callable<T> task)

已过时。

指定者:

submit 在接口中 ExecutorService

覆盖:

submit 在类中 AbstractExecutorService

submit

public <T> Future<T> submit(int hash,
                            Callable<T> task)

已过时。

waitingSize

public int waitingSize()

已过时。

shutdown

public void shutdown()

已过时。

shutdownNow

public List<Runnable> shutdownNow()

已过时。

isShutdown

public boolean isShutdown()

已过时。

isTerminated

public boolean isTerminated()

已过时。

awaitTermination

public boolean awaitTermination(long l,
                                TimeUnit tu)
                         throws InterruptedException

已过时。

抛出:

InterruptedException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
                throws InterruptedException,
                       ExecutionException

已过时。

指定者:

invokeAny 在接口中 ExecutorService

覆盖:

invokeAny 在类中 AbstractExecutorService

抛出:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
                       long timeout,
                       TimeUnit unit)
                throws InterruptedException,
                       ExecutionException,
                       TimeoutException

已过时。

指定者:

invokeAny 在接口中 ExecutorService

覆盖:

invokeAny 在类中 AbstractExecutorService

抛出:

InterruptedException

ExecutionException

TimeoutException

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
                              throws InterruptedException

已过时。

指定者:

invokeAll 在接口中 ExecutorService

覆盖:

invokeAll 在类中 AbstractExecutorService

抛出:

InterruptedException

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                                     long timeout,
                                     TimeUnit unit)
                              throws InterruptedException

已过时。

指定者:

invokeAll 在接口中 ExecutorService

覆盖:

invokeAll 在类中 AbstractExecutorService

抛出:

InterruptedException