java使用Executor(执行器)管理线程

简介:

v一.一个实现了Runnable接口的类

复制代码
class MyThread implements Runnable{
    private static int num = 0;
    @Override
    public void run() {
        while(true){
            synchronized(MyThread.class){
                ++num;
                try{
                    Thread.sleep(500);
                } catch(Exception e){
                    System.out.println(e.toString());
                }
                System.out.println(Thread.currentThread().getName() + " " + num);
            }
        }
    }
}
复制代码

v1. newCachedThreadPool()方法

  CacheThreadPool会为每一个任务创建一个线程。非常常见的情况是,单个的Executor被用来创建和管理系统中的任务。shutdown()方法可以防止新的任务被提交给这个Executor。如果在shutdown()方法之后提交新任务,则会抛出java.util.concurrent.RejectedExecutionException异常。

复制代码
public class Main{
    public static void main(String[] args){
          ExecutorService exes = Executors.newCachedThreadPool();
          for(int i=0; i<5; ++i)
              exes.execute(new MyThread());
          exes.shutdown();          
    }
}
复制代码

v2.FixedThreadPool()方法

  FixedThreadPool使用了优先的线程集来执行所提交的任务。有了它,你就可以一次性预先执行代价高的线程分配。也就是说如果设置的最大线程数量是x,而提交的线程数y,那么(y-x)对应的这些线程要等到前x个线程执行完毕才会执行。

  下面的例子中,线程6一直不会有机会执行。因为run()方法中是 while(true), 可以将while(true)去掉,前5个线程执行完毕后,才会执行第6个线程。

复制代码
public class Main{
    public static void main(String[] args){
          ExecutorService exes = Executors.newFixedThreadPool(5);
          for(int i=0; i<6; ++i)
                  exes.execute(new MyThread());
          exes.shutdown();          
    }
}
复制代码

v3.newSingleThreadExecutor()方法

复制代码
public class Main{
    public static void main(String[] args){        
          ExecutorService exes = Executors.newSingleThreadExecutor();
          for(int i=0; i<5; ++i)
              exes.execute(new MyThread());
          exes.shutdown();    
}
复制代码

  SingleThreadExecutor就像是线程数量为1的FixedThreadPool。这对于你希望在另一个线程中连续运行的事物(长期存活的任务)来说,都是很有用的。如果想SingleThreadExecutor提交了多个任务,那么这些任务将排队,每个任务都会在下一个任务开始之前结束,所有的任务将使用相同的线程。

 

v二.一个实现了Callable<E>接口的类(从任务中产生返回值)

复制代码
class MyThread implements Callable<String>{
    private static int num = 0;
    @Override
    public String call() throws Exception {
        for(int i=0; i<5; ++i){
            synchronized(MyThread.class){
                ++num;
                Thread.sleep(200);
                System.out.println(Thread.currentThread().getName() + " " + num);
            }
        }
        return Thread.currentThread().getName() + " success!";
    }
}
复制代码

v1.ExecutorService.submit()方法

复制代码
public class Main{
    public static void main(String[] args){
         ExecutorService exes = Executors.newCachedThreadPool();
         ArrayList<Future<String>> rets = new ArrayList<Future<String>>();
         for(int i=0; i<5; ++i)
             rets.add(exes.submit(new MyThread()));
         for(Future<String> fs : rets){
            try {
                System.out.println(fs.get());
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
         }
    }
}
复制代码

  submit()会产生Future对象,它用Callable返回结果的特定类型进行了参数化。可以调用Future的isDone()方法来查询Future是否已经完成。调用Future的get()方法来获取最终线程的执行结果。另外,Future的get()方法是一个阻塞方法,直到结果准备就绪

v 三.线程的优先级

复制代码
class MyThread implements Runnable{
    private int priority;
    public MyThread(){
    }
    
    public MyThread(int priority){
        this.priority = priority;
    }
    
    private static int num = 0;
    private volatile double d;
    @Override
    public void run() {
        Thread.currentThread().setPriority(priority);
        while(true){
            for(int i=0; i<100000; ++i){
                d += (Math.PI+Math.E)/(double)i;
                if(i%1000 == 0)
                    Thread.yield();
            }
            synchronized(MyThread.class){
                ++num;
                try{
                    Thread.sleep(500);
                } catch(Exception e){
                    System.out.println(e.toString());
                }
                System.out.println(Thread.currentThread().getName() + " " + num);
            }
        }
    }
}

public class Main{
    public static void main(String[] args){
         ExecutorService exes = Executors.newCachedThreadPool();
         for(int i=0; i<5; ++i)
             exes.execute(new MyThread(Thread.MIN_PRIORITY));
         exes.execute(new MyThread(Thread.MAX_PRIORITY));
         exes.shutdown();
    }
}
复制代码

  volatile变量保证编译器对循环不进行任何的优化,如果不加入这些运算的话,就不会看到设置线程优先级的效果。数学运算是可以中断的,向控制台打印不能被中断。这里预案算时间足够的长,因此线程调度机制才来的及介入,交换任务并关注优先级,是的最高优先级被优先选择。

v四.后台线程

复制代码
class SimpleDaemons implements Runnable{
    @Override
    public void run() {
        while(true){
            try{
                TimeUnit.MILLISECONDS.sleep(200);
                System.out.println(Thread.currentThread().getName());
            } catch(InterruptedException e){
                System.out.println(Thread.currentThread().getName() + " : InterruptException!");
                e.printStackTrace();
            }
        }
    }
}

public class Main{
    public static void main(String[] args) throws InterruptedException{
         for(int i=0; i<10; ++i){
             Thread daemon = new Thread(new SimpleDaemons());
             daemon.setDaemon(true);
             daemon.start();
         }
         System.out.println("All daemons started");
         TimeUnit.MILLISECONDS.sleep(1000);
    }
}
复制代码

  所谓后台线程,是指程序运行的时候在后台提供一种通用的服务的线程,并且这种线程并不属于程序中不可或缺的部分。因此,当所有的非后台线程结束时,程序也就终止了,同时会杀死进程中的所有的后台线程。反过来说,只要任何非后台线程还在运行,程序就不会终止。

  通过定制自己的ThreadFactory, 可以定制有Executor创建的线程的属性(后台,优先级,名称)

复制代码
class DaemonThreadFactory implements ThreadFactory{
    @Override
    public Thread newThread(Runnable r) {
        Thread t = new Thread(r);
        t.setDaemon(true);
        return t;
    }
}
复制代码
复制代码
class DaemonFromFactory implements Runnable{
    @Override
    public void run() {
        try{
            TimeUnit.MILLISECONDS.sleep(100);
            System.out.println(Thread.currentThread().getName());
        } catch (InterruptedException e){
            e.printStackTrace();
        }
    }
}

public class Main{
    public static void main(String[] args) throws InterruptedException{
         ExecutorService exes = Executors.newCachedThreadPool(new DaemonThreadFactory());
         for(int i=0; i<5; ++i)
                 exes.execute(new DaemonFromFactory());
         System.out.println("All Daemos Started!");
         TimeUnit.MILLISECONDS.sleep(1000);
    }
}









本文转自 小眼儿 博客园博客,原文链接:http://www.cnblogs.com/hujunzheng/p/5097470.html,如需转载请自行联系原作者
目录
相关文章
|
6天前
|
安全 Java API
java如何请求接口然后终止某个线程
通过本文的介绍,您应该能够理解如何在Java中请求接口并根据返回结果终止某个线程。合理使用标志位或 `interrupt`方法可以确保线程的安全终止,而处理好网络请求中的各种异常情况,可以提高程序的稳定性和可靠性。
37 6
|
19天前
|
存储 监控 小程序
Java中的线程池优化实践####
本文深入探讨了Java中线程池的工作原理,分析了常见的线程池类型及其适用场景,并通过实际案例展示了如何根据应用需求进行线程池的优化配置。文章首先介绍了线程池的基本概念和核心参数,随后详细阐述了几种常见的线程池实现(如FixedThreadPool、CachedThreadPool、ScheduledThreadPool等)的特点及使用场景。接着,通过一个电商系统订单处理的实际案例,分析了线程池参数设置不当导致的性能问题,并提出了相应的优化策略。最终,总结了线程池优化的最佳实践,旨在帮助开发者更好地利用Java线程池提升应用性能和稳定性。 ####
|
15天前
|
安全 算法 Java
Java多线程编程中的陷阱与最佳实践####
本文探讨了Java多线程编程中常见的陷阱,并介绍了如何通过最佳实践来避免这些问题。我们将从基础概念入手,逐步深入到具体的代码示例,帮助开发者更好地理解和应用多线程技术。无论是初学者还是有经验的开发者,都能从中获得有价值的见解和建议。 ####
|
15天前
|
Java 调度
Java中的多线程编程与并发控制
本文深入探讨了Java编程语言中多线程编程的基础知识和并发控制机制。文章首先介绍了多线程的基本概念,包括线程的定义、生命周期以及在Java中创建和管理线程的方法。接着,详细讲解了Java提供的同步机制,如synchronized关键字、wait()和notify()方法等,以及如何通过这些机制实现线程间的协调与通信。最后,本文还讨论了一些常见的并发问题,例如死锁、竞态条件等,并提供了相应的解决策略。
40 3
|
16天前
|
监控 Java 开发者
深入理解Java中的线程池实现原理及其性能优化####
本文旨在揭示Java中线程池的核心工作机制,通过剖析其背后的设计思想与实现细节,为读者提供一份详尽的线程池性能优化指南。不同于传统的技术教程,本文将采用一种互动式探索的方式,带领大家从理论到实践,逐步揭开线程池高效管理线程资源的奥秘。无论你是Java并发编程的初学者,还是寻求性能调优技巧的资深开发者,都能在本文中找到有价值的内容。 ####
|
19天前
|
监控 Java 数据库连接
Java线程管理:守护线程与用户线程的区分与应用
在Java多线程编程中,线程可以分为守护线程(Daemon Thread)和用户线程(User Thread)。这两种线程在行为和用途上有着明显的区别,了解它们的差异对于编写高效、稳定的并发程序至关重要。
27 2
|
19天前
|
监控 Java 开发者
Java线程管理:守护线程与本地线程的深入剖析
在Java编程语言中,线程是程序执行的最小单元,它们可以并行执行以提高程序的效率和响应性。Java提供了两种特殊的线程类型:守护线程和本地线程。本文将深入探讨这两种线程的区别,并探讨它们在实际开发中的应用。
27 1
|
2月前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念,包括进程和线程的定义、并发的实现方式,以及如何在C++中创建和管理线程,包括使用`std::thread`库、线程的join和detach方法,并通过示例代码展示了如何创建和使用多线程。
58 1
C++ 多线程之初识多线程
|
2月前
|
Java 开发者
在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口
【10月更文挑战第20天】在Java多线程编程中,创建线程的方法有两种:继承Thread类和实现Runnable接口。本文揭示了这两种方式的微妙差异和潜在陷阱,帮助你更好地理解和选择适合项目需求的线程创建方式。
27 3
|
2月前
|
Java 开发者
在Java多线程编程中,选择合适的线程创建方法至关重要
【10月更文挑战第20天】在Java多线程编程中,选择合适的线程创建方法至关重要。本文通过案例分析,探讨了继承Thread类和实现Runnable接口两种方法的优缺点及适用场景,帮助开发者做出明智的选择。
23 2
下一篇
DataWorks