zoukankan      html  css  js  c++  java
  • java 线程池的使用

    java  可以通过Executors 创建四类线程池:

    1、缓存线程池:Executors.newCachedTreadPool();创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。

    2、定长线程池:Executors.newFixedThreadPool();创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。

    3、定时线程池:Executors.newScheduledThreadPool();创建一个定长线程池,支持定时及周期性任务执行。

    4、单线程线程池:Executors.newSingleThreadExecutor();创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。

    这四种线程都有各自的优点和适合应用的场景。下面用代码列举下定长线程池:

    package com.java.main.test.thread;
    
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class ThreadForEditName {
        
        static final Map<String, Object> map = new ConcurrentHashMap<String, Object>();
        
        public static void main(String[] args) {
            
            ExecutorService service = Executors.newFixedThreadPool(4);
            
            for (int i = 0; i < 100; i++) {
                Runnable run = new TaskTread(i+1);
                Thread thread = new Thread(run);
                //thread.setName("thread>>:00"+i);
                //map.put("thread>>:00"+i, thread);
                service.execute(thread);
            }
            
        }
        
        static class TaskTread implements Runnable{
            
            private int num;
            
            public TaskTread(int num) {
                this.num = num;
            }
            
            @Override
            public void run() {
                String name = "myThread-"+num;
                Thread.currentThread().setName(name);
                map.put(name, this);
                System.out.println("开始线程:"+name);
                
                try {
                    Thread.sleep(5000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }finally{
                    map.remove(name);
                    System.out.println("移除:"+name);
                    System.out.println(map.size());
                }
            }
        }
    
    }
  • 相关阅读:
    LINUX 修复relocation error: /lib/tls/libc.so.6
    cmd 命令相关
    JS 相关
    Mysql 时间函数
    drupal 7.1 doc
    消息系统之Apache ActiveMQ
    【MongoDB学习之一】初始MongoDB
    【Redis学习之二】Redis:redis.conf 配置详解
    【Redis学习之一】Redis
    NOSQL学习之一:Memcached, Redis, MongoDB区别
  • 原文地址:https://www.cnblogs.com/phyxis/p/5535157.html
Copyright © 2011-2022 走看看