javafuturetask

A. java 有没有比threadpooltaskexecutor更好的多线程工具类

使用SPRING中的线程池ThreadPoolTaskExecutor实现并发。

一：不需要返回值的情况
1，初始化线程池
Java代码
ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPoolTaskExecutor();
poolTaskExecutor.setQueueCapacity(10000);
poolTaskExecutor.setCorePoolSize(5);
poolTaskExecutor.setMaxPoolSize(10);
poolTaskExecutor.setKeepAliveSeconds(5000);
poolTaskExecutor.initialize();

2，在线程池中执行某个线程
Java代码
poolTaskExecutor.execute(new Thread(Objct...){...});

二：需要返回值的情况
1，初始化线程池poolTaskExecutor，同上

2，新建一个类，实现Callable接口
Java代码
class GetFromDB implements Callable<User> {
private UserDao userDao;
private Long userId;

public GetFromDB(UserDao userDao, Long userId) {
this.userDao = userDao;
this.userId = userId;
}

public User call() throws DaoException {
User user = userDao.getUserById(userId);
return user;
}
}

3，用之前的GetFromDB类构造一个FutureTask类
Java代码
FutureTask<User> dbtask = new FutureTask<User>(GetFromDB);

4，提交并执行
Java代码
threadpool.submit(dbtask);

5，得到返回值
Java代码
try {
User user = dbtask.get();
} catch (Exception e) {
if (e instanceof ExecutionException
&& ((ExecutionException) e).getCause() instanceof DaoException) {
throw (DaoException) ((ExecutionException) e).getCause();
} else {
其他处理方式
}
}

注：一旦调用了get()方法，如果线程还未产生返回值，则将阻塞get()方法，直到得到返回值。基于此，如果你想确保线程执行完后才执行下一步操作，即使你不想得到返回值也可以调用一下此方法。当然这与多线程的初衷不符。

B. java多线程有几种实现方法

• 继承Thread类来实现多线程:

当我们自定义的类继承Thread类后，该类就为一个线程类,该类为一个独立的执行单元，线程代码必须编写在run()方法中,run方法是由Thread类定义，我们自己写的线程类必须重写run方法。

run方法中定义的代码为线程代码，但run方法不能直接调用，如果直接调用并没有开启新的线程而是将run方法交给调用的线程执行

要开启新的线程需要调用Thread类的start()方法，该方法自动开启一个新的线程并自动执行run方法中的内容




*java多线程的启动顺序不一定是线程执行的顺序，各个线程之间是抢占CPU资源执行的，所有有可能出现与启动顺序不一致的情况。




CPU的调用策略：

如何使用CPU资源是由操作系统来决定的，但操作系统只能决定CPU的使用策略不能控制实际获得CPU执行权的程序。




线程执行有两种方式：




1.抢占式：

目前PC机中使用最多的一种方式，线程抢占CPU的执行权，当一个线程抢到CPU的资源后并不是一直执行到此线程执行结束，而是执行一个时间片后让出CPU资源，此时同其他线程再次抢占CPU资源获得执行权。




2.轮循式;

每个线程执行固定的时间片后让出CPU资源，以此循环执行每个线程执行相同的时间片后让出CPU资源交给下一个线程执行。

C. java并发框架有哪些

Java并发框架java.util.concurrent是JDK5中引入到标准库中的(采用的是Doug
Lea的并发库)。该包下的类可以分为这么块：

Executors

1)接口：

Executor(例子涉及)：用来执行提交的Runnable任务的对象。是一个简单的标准化接口，用来定义包括线程池、异步IO、轻量级任务框架等等。任务可以由一个新创建的线程、一个已有任务执行线程、或是线程直接调用execute()来执行，可以串行也可并行执行，取决于使用的是哪个Executor具体类。

ExecutorService(例子涉及)：Executor的子接口，提供了一个更加具体的异步任务执行框架：提供了管理结束的方法，以及能够产生Future以跟踪异步任务进程的方法。一个ExcutorService管理着任务队列和任务调度。

ScheledExecutorService(例子涉及)：ExecutorService的子接口，增加了对延迟和定期任务执行的支持。

Callable(例子涉及)：一个返回结果或抛出异常的任务，实现类需要实现其中一个没有参数的叫做call的方法。Callabe类似于Runnable，但是Runnable不返回结果且不能抛出checked
exception。ExecutorService提供了安排Callable异步执行的方法。

Future(例子涉及)：代表一个异步计算的结果(由于是并发执行，结果可以在一段时间后才计算完成，其名字可能也就是代表这个意思吧)，提供了可判断执行是否完成以及取消执行的方法。

2)实现：

ThreadPoolExecutor和ScheledThreadPoolExecutor：可配置线程池(后者具备延迟或定期调度功能)。

Executors(例子涉及)：提供Executor、ExecutorService、ScheledExecutorService、ThreadFactory以及Callable的工厂方法及工具方法。

FutureTask：对Future的实现

ExecutorCompletionService(例子涉及)：帮助协调若干(成组)异步任务的处理。

Queues

非阻塞队列：ConcurrentLinkedQueue类提供了一个高效可伸缩线程安全非阻塞FIFO队列。

阻塞队列：BlockingQueue接口，有五个实现类：LinkedBlockingQueue(例子涉及)、ArrayBlockingQueue、SynchronousQueue、PriorityBlockingQueue和DelayQueue。他们对应了不同的应用环境：生产者/消费者、消息发送、并发任务、以及相关并发设计。

Timing

TimeUnit类(例子涉及)：提供了多种时间粒度(包括纳秒)用以表述和控制基于超时的操作。

Synchronizers 提供特定用途同步语境

Semaphore(例子涉及)：计数信号量，这是一种经典的并发工具。

CountDownLatch(例子涉及)：简单的倒计数同步工具，可以让一个或多个线程等待直到另外一些线程中的一组操作处理完成。

CyclicBarrier(例子涉及)：可重置的多路同步工具，可重复使用(CountDownLatch是不能重复使用的)。

Exchanger：允许两个线程在汇合点交换对象，在一些pipeline设计中非常有用。

Concurrent Collections

除队列外，该包还提供了一些为多线程上下文设计的集合实现：ConcurrentHashMap、CopyOnWriteArrayList及CopyOnWriteArraySet。

注意："Concurrent"前缀的类有别于"synchronized"前缀的类。“concurrent”集合是线程安全的，不需要由单排斥锁控制的(无锁的)。以ConcurrentHashMap为例，允许任何数量的并发读及可调数量的并发写。“Synchronized”类则一般通过一个单锁来防止对集合的所有访问，开销大且伸缩性差。