最终目的解决等待问题。
如果客户端只有一个线程,这个线程发起读取文件的操作必须等待IO 流返回,线程(客户端)才能做其他的事
客户端一个线程情况下,一个线程导致整个客户端阻塞。那么我们可以使用多线程,一部分线程在等待 IO 操作返回其他线程可以继续做其他的事。此时从客户端角度来说,客户端没有闲着。
在java中,有多种方式
继承Thread类、实现Runnable接口、使用ExecutorService、Callable、Future实现带返回结果的多线程。
继承Thread类
public class MyThread extends Thread{
public void run(){
System.out.println("MyThread.run()");
}
}
public static void main(String[] args){
MyThread myThread = new MyThread();
myThread.start();
}
实现Runable接口
public class MyThread implements Runnable {
public void run() {
System.out.println("MyThread.run()");
}
}
实现Callable接口通过FutureTask包装器来创建Thread线程
public class CallableDemo implements Callable<String> {
@Override
public String call() throws Exception {
int a = 1;
int b = 2;
System.out.println(a + b);
return "执行结果" + (a + b);
}
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executorService = Executors.newFixedThreadPool(1);
CallableDemo callableDemo = new CallableDemo();
Future<String> future = executorService.submit(callableDemo);
System.out.println(future.get());
executorService.shutdown();
}
}
zookeeper 源码: 通过阻塞队列以及多线程的方式,实现对请求的异步化处理,提升处理性能
阻塞队列:LinkedBlockingQueue(无界阻塞队列)
原文:https://www.cnblogs.com/snail-gao/p/11739463.html