线程池

先看几个概念：线程：进程中负责程序执行的执行单元。一个进程中至少有一个线程。

多线程：解决多任务同时执行的需求，合理使用CPU资源。多线程的运行是根据CPU切换完成，如何切换由CPU决定，因此多线程运行具有不确定性。

线程池：基本思想还是一种对象池的思想，开辟一块内存空间，里面存放了众多(未死亡)的线程，池中线程执行调度由池管理器来处理。当有线程任务时，从池中取一个，执行完成后线程对象归池，这样可以避免反复创建线程对象所带来的性能开销，节省了系统的资源。

线程池的优点 1）避免线程的创建和销毁带来的性能开销。 2）避免大量的线程间因互相抢占系统资源导致的阻塞现象。 3｝能够对线程进行简单的管理并提供定时执行、间隔执行等功能。

线程

创建线程的两种方式

继承Thread类，扩展线程


x
class DemoThread extends Thread {
@Override
public void run() {
    super.run();
    // Perform time-consuming operation...
}
}
DemoThread t = new DemoThread();
t.start();}

备注

线程和进程的区别 一个进程是一个独立(self contained)的运行环境，它可以被看作一个程序或者一个应用。而线程是在进程中执行的一个任务。线程是进程的子集，一个进程可以有很多线程，每条线程并行执行不同的任务。不同的进程使用不同的内存空间，而所有的线程共享一片相同的内存空间。别把它和栈内存搞混，每个线程都拥有单独的栈内存用来存储本地数据。

Thread 类中的 start() 和 run() 方法有什么区别？ 调用 start() 方法才会启动新线程；如果直接调用 Thread 的 run() 方法，它的行为就会和普通的方法一样；为了在新的线程中执行我们的代码，必须使用 Thread.start()

实现Runnabke接口


xxxxxxxxxx
public class DemoActivity extends BaseActivity implements Runnable {
@Override
public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    Thread t = new Thread(this);
    t.start();
}
@Override
public void run() {
}
}

学习笔记

1）用 Runnable 还是 Thread ？ 我们都知道可以通过继承 Thread 类或者调用 Runnable 接口来实现线程，问题是，创建线程哪种方式更好呢？什么情况下使用它？这个问题很容易回答，如果你知道Java不支持类的多重继承，但允许你调用多个接口。所以如果你要继承其他类，当然是调用Runnable接口更好了。

2）Runnable 和 Callable 有什么不同？ Runnable 和 Callable 都代表那些要在不同的线程中执行的任务。Runnable 从 JDK1.0 开始就有了，Callable 是在 JDK1.5 增加的。它们的主要区别是 Callable 的 call() 方法可以返回值和抛出异常，而 Runnable 的 run() 方法没有这些功能。Callable 可以返回装载有计算结果的 Future 对象。

多线程

多线程的概念很好理解就是多条线程同时存在，但要用好多线程确不容易，涉及到多线程间通信，多线程共用一个资源等诸多问题。 使用多线程的优缺点：优点： 1）适当的提高程序的执行效率（多个线程同时执行）。 2）适当的提高了资源利用率（CPU、内存等）。缺点： 1）占用一定的内存空间。 2）线程越多CPU的调度开销越大。 3）程序的复杂度会上升。

线程池

一种线程使用模式。线程过多会带来调度开销，进而影响缓存局部性和整体性能。而线程池维护着多个线程，等待着监督管理者分配可并发执行的任务。这避免了在处理短时间任务时创建与销毁线程的代价。线程池不仅能够保证内核的充分利用，还能防止过分调度。可用线程数量应该取决于可用的并发处理器、处理器内核、内存、网络sockets等的数量。例如，线程数一般取cpu数量+2比较合适，线程数过多会导致额外的线程切换开销。
线程池的优点 1）避免线程的创建和销毁带来的性能开销。 2）避免大量的线程间因互相抢占系统资源导致的阻塞现象。 3｝能够对线程进行简单的管理并提供定时执行、间隔执行等功能。

实现Runnable接口的Cache线程池

Executor执行Runnable任务


xxxxxxxxxx
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Main {
public static void main(String[] args){
    ExecutorService executorService = Executors.newCachedThreadPool();//创建一个缓冲线程池
//      ExecutorService executorService = Executors.newFixedThreadPool(5);
//      ExecutorService executorService = Executors.newSingleThreadExecutor();
    for (int i = 0; i < 5; i++){
        executorService.execute(new TestRunnable());//接受一个Runable实例，用来执行一个任务，任务即一个实现了Runnable接口的类。
        System.out.println("************* a" + i + " *************");
    }
    executorService.shutdown();//将线程池关闭
}
}
class TestRunnable implements Runnable{
public void run(){
    System.out.println(Thread.currentThread().getName() + "线程被调用了。");
}
}

运行结果如下

***** a0 ***** pool-1-thread-1线程被调用了。 ***** a1 ***** ***** a2 ***** ***** a3 ***** pool-1-thread-1线程被调用了。 pool-1-thread-3线程被调用了。 ***** a4 ***** pool-1-thread-2线程被调用了。 pool-1-thread-4线程被调用了。

我们从结果可以看出，CachedThreadPool在创建新线程前会检查线程池中有没有闲置的线程，如果有就调用，没有就新建线程

实现Callable的线程池

Executor执行Callable任务 '''Java import java.util.ArrayList; import java.util.List; import java.util.concurrent.*;


xxxxxxxxxx
public class CallableDemo{
public static void main(String[] args){
    ExecutorService executorService = Executors.newCachedThreadPool();
    List<Future<String>> resultList = new ArrayList<Future<String>>();
    //创建10个任务并执行 
    for (int i = 0; i < 10; i++){
        //使用ExecutorService执行Callable类型的任务，并将结果保存在future变量中 
        Future<String> future = executorService.submit(new TaskWithResult(i));
        //将任务执行结果存储到List中 
        resultList.add(future);
    }
    //遍历任务的结果 
    for (Future<String> fs : resultList){
        try{
            while(!fs.isDone());//Future返回如果没有完成，则一直循环等待，直到Future返回完成
            System.out.println(fs.get());     //打印各个线程（任务）执行的结果
        }catch(InterruptedException e){
            e.printStackTrace();
        }catch(ExecutionException e){
            e.printStackTrace();
        }finally{
            //启动一次顺序关闭，执行以前提交的任务，但不接受新任务
            executorService.shutdown();
        }
    }
}
}
class TaskWithResult implements Callable<String>{
private int id;
public TaskWithResult(int id){
    this.id = id;
}
/**
 * 任务的具体过程，一旦任务传给ExecutorService的submit方法，
 * 则该方法自动在一个线程上执行
 */
public String call() throws Exception {
    System.out.println("call()方法被自动调用！！！    " + Thread.currentThread().getName());
    //该返回结果将被Future的get方法得到
    return "call()方法被自动调用，任务返回的结果是：" + id + "    " + Thread.currentThread().getName();
}
}

运行结果如下：

call()方法被自动调用！！！ pool-1-thread-1 call()方法被自动调用，任务返回的结果是：0 pool-1-thread-1 call()方法被自动调用！！！ pool-1-thread-2 call()方法被自动调用！！！ pool-1-thread-3 call()方法被自动调用！！！ pool-1-thread-4 call()方法被自动调用，任务返回的结果是：1 pool-1-thread-2 call()方法被自动调用！！！ pool-1-thread-5 call()方法被自动调用，任务返回的结果是：2 pool-1-thread-3 call()方法被自动调用，任务返回的结果是：3 pool-1-thread-4 call()方法被自动调用，任务返回的结果是：4 pool-1-thread-5 call()方法被自动调用！！！ pool-1-thread-6 call()方法被自动调用，任务返回的结果是：5 pool-1-thread-6 call()方法被自动调用！！！ pool-1-thread-7 call()方法被自动调用，任务返回的结果是：6 pool-1-thread-7 call()方法被自动调用！！！ pool-1-thread-8 call()方法被自动调用！！！ pool-1-thread-9 call()方法被自动调用，任务返回的结果是：7 pool-1-thread-8 call()方法被自动调用，任务返回的结果是：8 pool-1-thread-9 call()方法被自动调用！！！ pool-1-thread-10 call()方法被自动调用，任务返回的结果是：9 pool-1-thread-10

从结果中可以同样可以看出，submit也是首先选择空闲线程来执行任务，如果没有，才会创建新的线程来执行任务。另外，需要注意：如果Future的返回尚未完成，则get（）方法会阻塞等待，直到Future完成返回，可以通过调用isDone（）方法判断Future是否完成了返回。

自定义线程池

自定义线程池，可以用ThreadPoolExecutor类创建，它有多个构造方法来创建线程池，用该类很容易实现自定义的线程池，这里先贴上示例程序：


xxxxxxxxxx
import java.util.concurrent.ArrayBlockingQueue; 
import java.util.concurrent.BlockingQueue; 
import java.util.concurrent.ThreadPoolExecutor; 
import java.util.concurrent.TimeUnit; 
 
public class ThreadPoolTest{ 
public static void main(String[] args){ 
    //创建等待队列 
    BlockingQueue<Runnable> bqueue = new ArrayBlockingQueue<Runnable>(20); 
    //创建线程池，池中保存的线程数为3，允许的最大线程数为5
    ThreadPoolExecutor pool = new ThreadPoolExecutor(3,5,50,TimeUnit.MILLISECONDS,bqueue); 
    //创建七个任务 
    Runnable t1 = new MyThread(); 
    Runnable t2 = new MyThread(); 
    Runnable t3 = new MyThread(); 
    Runnable t4 = new MyThread(); 
    Runnable t5 = new MyThread(); 
    Runnable t6 = new MyThread(); 
    Runnable t7 = new MyThread(); 
    //每个任务会在一个线程上执行
    pool.execute(t1); 
    pool.execute(t2); 
    pool.execute(t3); 
    pool.execute(t4); 
    pool.execute(t5); 
    pool.execute(t6); 
    pool.execute(t7); 
    //关闭线程池 
    pool.shutdown(); 
} 
} 
 
class MyThread implements Runnable{ 
@Override
public void run(){ 
    System.out.println(Thread.currentThread().getName() + "正在执行。。。"); 
    try{ 
        Thread.sleep(100); 
    }catch(InterruptedException e){ 
        e.printStackTrace(); 
    } 
} 
}

运行结果如下：

pool-1-thread-2正在执行。。。 pool-1-thread-3正在执行。。。 pool-1-thread-1正在执行。。。 pool-1-thread-1正在执行。。。 pool-1-thread-3正在执行。。。 pool-1-thread-2正在执行。。。 pool-1-thread-2正在执行。。。

*从结果中可以看出，七个任务是在线程池的三个线程上执行的。这里简要说明下用到的ThreadPoolExecuror类的构造方法中各个参数的含义。

public ThreadPoolExecutor (int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit,BlockingQueue workQueue) corePoolSize：线程池中所保存的核心线程数，包括空闲线程。

maximumPoolSize：池中允许的最大线程数。

keepAliveTime：线程池中的空闲线程所能持续的最长时间。

unit：持续时间的单位。

workQueue：任务执行前保存任务的队列，仅保存由execute方法提交的Runnable任务。

根据ThreadPoolExecutor源码前面大段的注释，我们可以看出，当试图通过excute方法讲一个Runnable任务添加到线程池中时，按照如下顺序来处理：

1、如果线程池中的线程数量少于corePoolSize，即使线程池中有空闲线程，也会创建一个新的线程来执行新添加的任务；

2、如果线程池中的线程数量大于等于corePoolSize，但缓冲队列workQueue未满，则将新添加的任务放到workQueue中，按照FIFO的原则依次等待执行（线程池中有线程空闲出来后依次将缓冲队列中的任务交付给空闲的线程执行）；

3、如果线程池中的线程数量大于等于corePoolSize，且缓冲队列workQueue已满，但线程池中的线程数量小于maximumPoolSize，则会创建新的线程来处理被添加的任务；

4、如果线程池中的线程数量等于了maximumPoolSize，有4种才处理方式（该构造方法调用了含有5个参数的构造方法，并将最后一个构造方法为RejectedExecutionHandler类型，它在处理线程溢出时有4种方式，这里不再细说，要了解的，自己可以阅读下源码）。

总结起来，也即是说，当有新的任务要处理时，先看线程池中的线程数量是否大于corePoolSize，再看缓冲队列workQueue是否满，最后看线程池中的线程数量是否大于maximumPoolSize。

另外，当线程池中的线程数量大于corePoolSize时，如果里面有线程的空闲时间超过了keepAliveTime，就将其移除线程池，这样，可以动态地调整线程池中线程的数量。*

学习笔记我们大致来看下Executors的源码，newCachedThreadPool的不带RejectedExecutionHandler参数（即第五个参数，线程数量超过maximumPoolSize时，指定处理方式）的构造方法如下：


xxxxxxxxxx
public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                              60L, TimeUnit.SECONDS,
                              new SynchronousQueue<Runnable>());
}

它将corePoolSize设定为0，而将maximumPoolSize设定为了Integer的最大值，线程空闲超过60秒，将会从线程池中移除。由于核心线程数为0，因此每次添加任务，都会先从线程池中找空闲线程，如果没有就会创建一个线程（SynchronousQueue决定的，后面会说）来执行新的任务，并将该线程加入到线程池中，而最大允许的线程数为Integer的最大值，因此这个线程池理论上可以不断扩大。

再来看newFixedThreadPool的不带RejectedExecutionHandler参数的构造方法，如下：


xxxxxxxxxx
public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor(nThreads, nThreads,
                              0L, TimeUnit.MILLISECONDS,
                              new LinkedBlockingQueue<Runnable>());
}

它将corePoolSize和maximumPoolSize都设定为了nThreads，这样便实现了线程池的大小的固定，不会动态地扩大，另外，keepAliveTime设定为了0，也就是说线程只要空闲下来，就会被移除线程池，敢于LinkedBlockingQueue下面会说。

下面说说几种排队的策略：

1、直接提交。缓冲队列采用 SynchronousQueue，它将任务直接交给线程处理而不保持它们。如果不存在可用于立即运行任务的线程（即线程池中的线程都在工作），则试图把任务加入缓冲队列将会失败，因此会构造一个新的线程来处理新添加的任务，并将其加入到线程池中。直接提交通常要求无界 maximumPoolSizes（Integer.MAX_VALUE）以避免拒绝新提交的任务。newCachedThreadPool采用的便是这种策略。

2、无界队列。使用无界队列（典型的便是采用预定义容量的 LinkedBlockingQueue，理论上是该缓冲队列可以对无限多的任务排队）将导致在所有 corePoolSize 线程都工作的情况下将新任务加入到缓冲队列中。这样，创建的线程就不会超过 corePoolSize，也因此，maximumPoolSize 的值也就无效了。当每个任务完全独立于其他任务，即任务执行互不影响时，适合于使用无界队列。newFixedThreadPool采用的便是这种策略。

3、有界队列。当使用有限的 maximumPoolSizes 时，有界队列（一般缓冲队列使用ArrayBlockingQueue，并制定队列的最大长度）有助于防止资源耗尽，但是可能较难调整和控制，队列大小和最大池大小需要相互折衷，需要设定合理的参数。

循序渐进Socket网络编程（多客户端、信息共享、文件传输）

一月 27, 2019

循序渐进Socket网络编程（多客户端、信息共享、文件传输）前言：在最近一个即将结束的项目中使用到了Socket编程，用于调用另一系统进行处理并返回数据。故把Socket的基础知识总结梳理一遍。 1、TCP/IP协议　　既然是网络编程，涉及几个系统之间的交互，那么首先要考虑的是如何准确的定位到网络上的一台或几台主机，另一个是如何进行可靠高效的数据传输。这里就要使用到TCP/IP协议。　　TCP/IP协议（传输控制协议）由网络层的IP协议和传输层的TCP协议组成。IP层负责网络主机的定位，数据传输的路由，由IP地址可以唯一的确定Internet上的一台主机。TCP层负责面向应用的可靠的或非可靠的数据传输机制，这是网络编程的主要对象。 2、TCP与UDP 　　TCP是一种面向连接的保证可靠传输的协议。通过TCP协议传输，得到的是一个顺序的无差错的数据流。发送方和接收方的成对的两个socket之间必须建立连接，以便在TCP协议的基础上进行通信，当一个socket（通常都是server socket）等待建立连接时，另一个socket可以要求进行连接，一旦这两个socket连接起来，它们就可以进行双向数据传输，双方都可以进行发送或接收操作。　　UDP是一种面向无连接的协议，每个数据报都是一个独立的信息，包括完整的源地址或目的地址，它在网络上以任何可能的路径传往目的地，因此能否到达目的地，到达目的地的时间以及内容的正确性都是不能被保证的。 TCP与UDP区别： TCP特点： TCP是面向连接的协议，通过三次握手建立连接，通讯完成时要拆除连接，由于TCP是面向连接协议，所以只能用于点对点的通讯。而且建立连接也需要消耗时间和开销。 TCP传输数据无大小限制，进行大数据传输。 TCP是一个可靠的协议，它能保证接收方能够完整正确地接收到发送方发送的全部数据。 UDP特点： UDP是面向无连接的通讯协议，UDP数据包括目的端口号和源端口号信息，由于通讯不需要连接，所以可以实现广播发送。 UDP传输数据时有大小限制，每个被传输的数据报必须限定在64KB之内。 UDP是一个不可靠的协议，发送方所发送的数据报并不一定以相同的次序到达接收方。 TCP与UDP应用： TCP在网络通信上有极强的生命力，例如远程连接（Telnet）和文件传输（FTP）都需要不定长度的数据被可靠...

阅读全文

搜索此博客

lee的学习生活blog

线程池

线程

继承Thread类，扩展线程

实现Runnabke接口

多线程

线程池

实现Runnable接口的Cache线程池

实现Callable的线程池

自定义线程池

评论

发表评论

此博客中的热门博文

Qbittorent下载完成后自动上传谷歌网盘脚本

记一次被骗的经历

循序渐进Socket网络编程（多客户端、信息共享、文件传输）