java销毁线程池(java 销毁线程)

本篇文章给大家谈谈java销毁线程池,以及java 销毁线程对应的知识点,希望对各位有所帮助,不要忘了收藏本站喔。

本文目录一览:

1、java线程池怎么实现的2、线程池里的线程怎么手动销毁线程3、java销毁线程池

java线程池怎么实现的

线程池简介:

多线程技术主要解决处理器单元内多个线程执行的问题,它可以显著减少处理器单元的闲置时间,增加处理器单元的吞吐能力。

假设一个服务器完成一项任务所需时间为:T1 创建线程时间,T2 在线程中执行任务的时间,T3 销毁线程时间。

如果:T1 + T3 远大于 T2,则可以采用线程池,以提高服务器性能。

一个线程池包括以下四个基本组成部分:

1、线程池管理器(ThreadPool):用于创建并管理线程池,包括 创建线程池,销毁线程池,添加新任务;

2、工作线程(PoolWorker):线程池中线程,在没有任务时处于等待状态,可以循环的执行任务;

3、任务接口(Task):每个任务必须实现的接口,以供工作线程调度任务的执行,它主要规定了任务的入口,任务执行完后的收尾工作,任务的执行状态等;

4、任务队列(taskQueue):用于存放没有处理的任务。提供一种缓冲机制。

线程池技术正是关注如何缩短或调整T1,T3时间的技术,从而提高服务器程序性能的。它把T1,T3分别安排在服务器程序的启动和结束的时间段或者一些空闲的时间段,这样在服务器程序处理客户请求时,不会有T1,T3的开销了。

线程池不仅调整T1,T3产生的时间段,而且它还显著减少了创建线程的数目,看一个例子:

假设一个服务器一天要处理50000个请求,并且每个请求需要一个单独的线程完成。在线程池中,线程数一般是固定的,所以产生线程总数不会超过线程池中线程的数目,而如果服务器不利用线程池来处理这些请求则线程总数为50000。一般线程池大小是远小于50000。所以利用线程池的服务器程序不会为了创建50000而在处理请求时浪费时间,从而提高效率。

代码实现中并没有实现任务接口,而是把Runnable对象加入到线程池管理器(ThreadPool),然后剩下的事情就由线程池管理器(ThreadPool)来完成了

package mine.util.thread;  

  

import java.util.LinkedList;  

import java.util.List;  

  

/** 

 * 线程池类,线程管理器:创建线程,执行任务,销毁线程,获取线程基本信息 

 */  

public final class ThreadPool {  

    // 线程池中默认线程的个数为5  

    private static int worker_num = 5;  

    // 工作线程  

    private WorkThread[] workThrads;  

    // 未处理的任务  

    private static volatile int finished_task = 0;  

    // 任务队列,作为一个缓冲,List线程不安全  

    private ListRunnable taskQueue = new LinkedListRunnable();  

    private static ThreadPool threadPool;  

  

    // 创建具有默认线程个数的线程池  

    private ThreadPool() {  

        this(5);  

    }  

  

    // 创建线程池,worker_num为线程池中工作线程的个数  

    private ThreadPool(int worker_num) {  

        ThreadPool.worker_num = worker_num;  

        workThrads = new WorkThread[worker_num];  

        for (int i = 0; i  worker_num; i++) {  

            workThrads[i] = new WorkThread();  

            workThrads[i].start();// 开启线程池中的线程  

        }  

    }  

  

    // 单态模式,获得一个默认线程个数的线程池  

    public static ThreadPool getThreadPool() {  

        return getThreadPool(ThreadPool.worker_num);  

    }  

  

    // 单态模式,获得一个指定线程个数的线程池,worker_num(0)为线程池中工作线程的个数  

    // worker_num=0创建默认的工作线程个数  

    public static ThreadPool getThreadPool(int worker_num1) {  

        if (worker_num1 = 0)  

            worker_num1 = ThreadPool.worker_num;  

        if (threadPool == null)  

            threadPool = new ThreadPool(worker_num1);  

        return threadPool;  

    }  

  

    // 执行任务,其实只是把任务加入任务队列,什么时候执行有线程池管理器觉定  

    public void execute(Runnable task) {  

        synchronized (taskQueue) {  

            taskQueue.add(task);  

            taskQueue.notify();  

        }  

    }  

  

    // 批量执行任务,其实只是把任务加入任务队列,什么时候执行有线程池管理器觉定  

    public void execute(Runnable[] task) {  

        synchronized (taskQueue) {  

            for (Runnable t : task)  

                taskQueue.add(t);  

            taskQueue.notify();  

        }  

    }  

  

    // 批量执行任务,其实只是把任务加入任务队列,什么时候执行有线程池管理器觉定  

    public void execute(ListRunnable task) {  

        synchronized (taskQueue) {  

            for (Runnable t : task)  

                taskQueue.add(t);  

            taskQueue.notify();  

        }  

    }  

  

    // 销毁线程池,该方法保证在所有任务都完成的情况下才销毁所有线程,否则等待任务完成才销毁  

    public void destroy() {  

        while (!taskQueue.isEmpty()) {// 如果还有任务没执行完成,就先睡会吧  

            try {  

                Thread.sleep(10);  

            } catch (InterruptedException e) {  

                e.printStackTrace();  

            }  

        }  

        // 工作线程停止工作,且置为null  

        for (int i = 0; i  worker_num; i++) {  

            workThrads[i].stopWorker();  

            workThrads[i] = null;  

        }  

        threadPool=null;  

        taskQueue.clear();// 清空任务队列  

    }  

  

    // 返回工作线程的个数  

    public int getWorkThreadNumber() {  

        return worker_num;  

    }  

  

    // 返回已完成任务的个数,这里的已完成是只出了任务队列的任务个数,可能该任务并没有实际执行完成  

    public int getFinishedTasknumber() {  

        return finished_task;  

    }  

  

    // 返回任务队列的长度,即还没处理的任务个数  

    public int getWaitTasknumber() {  

        return taskQueue.size();  

    }  

  

    // 覆盖toString方法,返回线程池信息:工作线程个数和已完成任务个数  

    @Override  

    public String toString() {  

        return “WorkThread number:” + worker_num + ”  finished task number:”  

                + finished_task + ”  wait task number:” + getWaitTasknumber();  

    }  

  

    /** 

     * 内部类,工作线程 

     */  

    private class WorkThread extends Thread {  

        // 该工作线程是否有效,用于结束该工作线程  

        private boolean isRunning = true;  

  

        /* 

         * 关键所在啊,如果任务队列不空,则取出任务执行,若任务队列空,则等待 

         */  

        @Override  

        public void run() {  

            Runnable r = null;  

            while (isRunning) {// 注意,若线程无效则自然结束run方法,该线程就没用了  

                synchronized (taskQueue) {  

                    while (isRunning  taskQueue.isEmpty()) {// 队列为空  

                        try {  

                            taskQueue.wait(20);  

                        } catch (InterruptedException e) {  

                            e.printStackTrace();  

                        }  

                    }  

                    if (!taskQueue.isEmpty())  

                        r = taskQueue.remove(0);// 取出任务  

                }  

                if (r != null) {  

                    r.run();// 执行任务  

                }  

                finished_task++;  

                r = null;  

            }  

        }  

  

        // 停止工作,让该线程自然执行完run方法,自然结束  

        public void stopWorker() {  

            isRunning = false;  

        }  

    }  

}

java销毁线程池(java 销毁线程)

线程池里的线程怎么手动销毁线程

线程池里的线程无法手动销毁线程。线程池里的线程只有在,设置退出标签当中才能销毁。

java销毁线程池

你是用Java自带的ExecutorService这个线程池么?如果是的话,ExecutorService自身会管理池中的线程,不需外界手动干预。

如果是自己写的话,必须在线程池内的线程加入退出判定,要不然的话是没法从线程外结束线程的。(你也不应该这样做,因为这样会导致验证的资源泄漏)

关于java销毁线程池和java 销毁线程的介绍到此就结束了,不知道你从中找到你需要的信息了吗 ?如果你还想了解更多这方面的信息,记得收藏关注本站。

本文来自投稿,不代表【】观点,发布者:【

本文地址: ,如若转载,请注明出处!

举报投诉邮箱:253000106@qq.com

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2024年3月30日 00:12:35
下一篇 2024年3月30日 00:19:50

相关推荐

  • 深入java虚拟机pdf,深入java虚拟机 中村成洋 pdf

    在linux环境下,java怎么实现从word格式转换为pdf格式 //设置当前使用的打印机,我的Adobe Distiller打印机名字为 Adobe PDF wordCom.setProperty( ActivePrinter , new Variant( Adobe PDF ));//设置printout的参数,将word文档打印为postscript…

    2024年5月23日
    4400
  • java截取指定长度字符串,java截取指定字符串之后的

    java中如何截取字符串中的指定一部分 第一个参数是开始截取的字符位置。(从0开始)第二个参数是结束字符的位置+1。(从0开始)indexof函数的作用是查找该字符串中的某个字的位置,并且返回。 int end);截取s中从begin开始至end结束时的字符串,并将其赋值给s;split讲解:java.lang.string.split split 方法 将…

    2024年5月23日
    4200
  • java绑定一个端口,java使用端口

    java如何多个service共用一个端口 你如果有多个项目的话,你可以把多个项目放到一个tomcat里面,这样端口相同使用项目名称来进行区分项目。你如果非要使用同一个,你也可以配置不同的域名导向不同的项目。就是访问的域名不同转接到的项目不同。 如果需要同时启动多个程序,要么修改tomcat的配置文件中的监听端口。要么修改jar包程序的监听端口。不能在一台服…

    2024年5月23日
    3400
  • java多线程并发编程基础,Java多线程并发执行返回

    电脑培训分享Java并发编程:核心理论 电脑培训发现本系列会从线程间协调的方式(wait、notify、notifyAll)、Synchronized及Volatile的本质入手,详细解释JDK为我们提供的每种并发工具和底层实现机制。 人们开始意识到了继承的众多缺点,开始努力用聚合代替继承。软件工程解决扩展性的重要原则就是抽象描述,直接使用的工具就是接口。接…

    2024年5月23日
    4600
  • 自学java找工作,自学java找工作需要包装简历吗

    自学java学多久可以找到工作 1、自学Java至少需要一年以上的时间才能达到找工作的水平。报班培训四到六个月的时间就可以找到一份不错的工作。 2、自学Java至少需要一年以上的时间才能达到找工作的水平。 3、如果要想找到一份Java相关的工作,需要至少学习5-6个月时间才能就业。Java开发需要掌握一些基础的编程语言知识,比如掌握面向对象的编程思想、基本的…

    2024年5月23日
    4300
  • java左移右移,java 左移

    java位移问题 1、思路:直接用Integer类的bit运算操作。 2、移位操作:左移:向左移位,符号后面的数字是移了多少位,移的位用0补齐,例如2进制数01111111左移一位后变为11111110,移位是字节操作。 3、Java 位运算 Java 位运算[转]一,Java 位运算表示方法: 在Java语言中,二进制数使用补码表示,最高位为符号位,正数的…

    2024年5月23日
    4200
  • java技术规范,java规范性要求

    现在主流的JAVA技术是什么? java最流行开发技术程序员必看 1 、Git Git一直是世界上最受欢迎的Java工具之一,也是Java开发人员最杰出的工具之一。Git是一个开源工具,是-种出色的分布式版本控制解决方案。 (1).Java基础语法、数组、类与对象、继承与多态、异常、范型、集合、流与文件、反射、枚举、自动装箱和注解。(2).Java面向对象编…

    2024年5月23日
    4000
  • javasocket编程,Java socket编程中,禁用nagle算法的参数

    Java进行并发多连接socket编程 1、Java可利用ServerSocket类对外部客户端提供多个socket接口。基本的做法是先创建一个ServerSocket实例,并绑定一个指定的端口,然后在这个实例上调用accept()方法等待客户端的连接请求。 2、Socket socket=server.accept(0;Thread handleThrea…

    2024年5月23日
    4600
  • javaservlet是不是线程安全的,servlet线程安全吗

    java问题,servlet问题,servlet在什么时候被初始化?它是线程安全吗? Servlet处于服务器进程中,它通过多线程方式运行其service方法,一个实例可以服务于多个请求。所以Servlet是线程不安全的。 ServletContext是可以多线程同时读/写属性的,线程是不安全的。要对属性的读写进行同步处理或者进行深度Clone()。 Ser…

    2024年5月23日
    5200
  • java死亡,java死代码是什么意思

    我的世界传送回死亡点指令是什么? 1、下面就让我们一起来了解一下吧:我的世界回到死的地方的指令是输入/back,就可以回到死亡地点了,当然也可以看信标,因为死亡后会有一道光集中在死亡点,只要循着光就可以找到目的地了。 2、在服务器中的指令 首先打开指令台,在指令行输入“/back”就可以回到自己的死亡地点了。在单人游戏中的指令 在单人游戏中,您无法直接返回到…

    2024年5月23日
    4800

发表回复

登录后才能评论



关注微信