`
mymobile
  • 浏览: 182790 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

Java:使用Executors创建和管理线程(转载)

阅读更多


1. 类 Executors

  此类中提供的一些方法有:

  1.1 public static ExecutorService newCachedThreadPool()

  创建一个可根据需要创建新线程的线程池,但是在以前构造的线程可用时将重用它们。对于执行很多短期异步任务的程序而言,这些线程池通常可提高程序性能。

  1.2 public static ExecutorService newFixedThreadPool(int nThreads)

  创建一个可重用固定线程数的线程池,以共享的无界队列方式来运行这些线程。

  1.3 public static ExecutorService newSingleThreadExecutor()

  创建一个使用单个 worker 线程的 Executor,以无界队列方式来运行该线程。

  这三个方法都可以配合接口ThreadFactory的实例一起使用。并且返回一个ExecutorService接口的实例。

  2. 接口 ThreadFactory

  根据需要创建新线程的对象。使用线程工厂就无需再手工编写对 new Thread 的调用了,从而允许应用程序使用特殊的线程子类、属性等等。

  此接口最简单的实现就是:

 


class SimpleThreadFactory implements ThreadFactory {
  public Thread newThread(Runnable r) {
  return new Thread(r);
  }
  }

  3. 接口ExecutorService

  该接口提供了管理终止的方法。

  4.创建标准线程池启动线程

  4.1 提供一个简单的实现Runnable接口的线程

 


 MyThread.java
  package com.zj.concurrency.executors;
  public class MyThread implements Runnable {
  private int count = 1, number;
  public MyThread(int num) {
  number = num;
  System.out.println("Create Thread-" + number);
  }
  public void run() {
  while (true) {
  System.out.println("Thread-" + number + " run " + count+" time(s)");
  if (++count == 3)
  return;
  }
  }
  }

  这个线程会打印出相应的创建和执行信息。

  4.2使用CachedThreadPool启动线程

 


 CachedThreadPool.java
  package com.zj.concurrency.executors;
  import java.util.concurrent.ExecutorService;
  import java.util.concurrent.Executors;
  public class CachedThreadPool {
  public static void main(String[] args) {
  ExecutorService exec = Executors.newCachedThreadPool();
  for (int i = 0; i < 5; i++)
  exec.execute(new MyThread(i));
  exec.shutdown();
  }
  }

  结果:

  Create Thread-0

  Create Thread-1

  Create Thread-2

  Create Thread-3

  Thread-0 run 1 time(s)

  Thread-0 run 2 time(s)

  Thread-1 run 1 time(s)

  Thread-1 run 2 time(s)

  Thread-2 run 1 time(s)

  Thread-2 run 2 time(s)

  Create Thread-4

  Thread-4 run 1 time(s)

  Thread-4 run 2 time(s)

  Thread-3 run 1 time(s)

  Thread-3 run 2 time(s)

  4.3 使用FixedThreadPool启动线程

 


 FixedThreadPool.java
  package com.zj.concurrency.executors;
  import java.util.concurrent.ExecutorService;
  import java.util.concurrent.Executors;
  public class FixedThreadPool {
  public static void main(String[] args) {
  ExecutorService exec = Executors.newFixedThreadPool(2);
  for (int i = 0; i < 5; i++)
  exec.execute(new MyThread(i));
  exec.shutdown();
  }
  }

  结果:

  Create Thread-0

  Create Thread-1

  Create Thread-2

  Create Thread-3

  Create Thread-4

  Thread-0 run 1 time(s)

  Thread-0 run 2 time(s)

  Thread-2 run 1 time(s)

  Thread-2 run 2 time(s)

  Thread-3 run 1 time(s)

  Thread-3 run 2 time(s)

  Thread-4 run 1 time(s)

  Thread-4 run 2 time(s)

  Thread-1 run 1 time(s)

  Thread-1 run 2 time(s)

  4.4 使用SingleThreadExecutor启动线程

 


 SingleThreadExecutor.java
  package com.zj.concurrency.executors;
  import java.util.concurrent.ExecutorService;
  import java.util.concurrent.Executors;
  public class SingleThreadExecutor {
  public static void main(String[] args) {
  ExecutorService exec = Executors.newSingleThreadExecutor();
  for (int i = 0; i < 5; i++)
  exec.execute(new MyThread(i));
  exec.shutdown();
  }
  }

  结果:

  Create Thread-0

  Create Thread-1

  Create Thread-2

  Create Thread-3

  Create Thread-4

  Thread-0 run 1 time(s)

  Thread-0 run 2 time(s)

  Thread-1 run 1 time(s)

  Thread-1 run 2 time(s)

  Thread-2 run 1 time(s)

  Thread-2 run 2 time(s)

  Thread-3 run 1 time(s)

  Thread-3 run 2 time(s)

  Thread-4 run 1 time(s)

  Thread-4 run 2 time(s)

5.配合ThreadFactory接口的使用

  我们试图给线程加入daemon和priority的属性设置。

  5.1设置后台线程属性

 


 DaemonThreadFactory.java
  package com.zj.concurrency.executors.factory;
  import java.util.concurrent.ThreadFactory;
  public class DaemonThreadFactory implements ThreadFactory {
  public Thread newThread(Runnable r) {
  Thread t = new Thread(r);
  t.setDaemon(true);
  return t;
  }
  }

  5.2 设置优先级属性

 


     最高优先级MaxPriorityThreadFactory.java
  package com.zj.concurrency.executors.factory;
  import java.util.concurrent.ThreadFactory;
  public class MaxPriorityThreadFactory implements ThreadFactory {
  public Thread newThread(Runnable r) {
  Thread t = new Thread(r);
  t.setPriority(Thread.MAX_PRIORITY);
  return t;
  }
  }

 


   最低优先级MinPriorityThreadFactory.java
  package com.zj.concurrency.executors.factory;
  import java.util.concurrent.ThreadFactory;
  public class MinPriorityThreadFactory implements ThreadFactory {
  public Thread newThread(Runnable r) {
  Thread t = new Thread(r);
  t.setPriority(Thread.MIN_PRIORITY);
  return t;
  }
  }

  5.3启动带有属性设置的线程

 

 


 ExecFromFactory.java
  package com.zj.concurrency.executors;
  import java.util.concurrent.ExecutorService;
  import java.util.concurrent.Executors;
  import com.zj.concurrency.executors.factory.DaemonThreadFactory;
  import com.zj.concurrency.executors.factory.MaxPriorityThreadFactory;
  import com.zj.concurrency.executors.factory.MinPriorityThreadFactory;
  public class ExecFromFactory {
  public static void main(String[] args) throws Exception {
  ExecutorService defaultExec = Executors.newCachedThreadPool();
  ExecutorService daemonExec = Executors
  .newCachedThreadPool(new DaemonThreadFactory());
  ExecutorService maxPriorityExec = Executors
  .newCachedThreadPool(new MaxPriorityThreadFactory());
  ExecutorService minPriorityExec = Executors
  .newCachedThreadPool(new MinPriorityThreadFactory());
  for (int i = 0; i < 10; i++)
  daemonExec.execute(new MyThread(i));
  for (int i = 10; i < 20; i++)
  if (i == 10)
  maxPriorityExec.execute(new MyThread(i));
  else if (i == 11)
  minPriorityExec.execute(new MyThread(i));
  else
  defaultExec.execute(new MyThread(i));
  }
  }

  结果:

  Create Thread-0

  Create Thread-1

  Create Thread-2

  Create Thread-3

  Thread-0 run 1 time(s)

  Thread-0 run 2 time(s)

  Thread-1 run 1 time(s)

  Thread-1 run 2 time(s)

  Thread-2 run 1 time(s)

  Thread-2 run 2 time(s)

  Create Thread-4

  Thread-4 run 1 time(s)

  Thread-4 run 2 time(s)

  Create Thread-5

  Thread-5 run 1 time(s)

  Thread-5 run 2 time(s)

  Create Thread-6

  Create Thread-7

  Thread-7 run 1 time(s)

  Thread-7 run 2 time(s)

  Create Thread-8

  Thread-8 run 1 time(s)

  Thread-8 run 2 time(s)

  Create Thread-9

  Create Thread-10

  Thread-10 run 1 time(s)

  Thread-10 run 2 time(s)

  Create Thread-11

  Thread-9 run 1 time(s)

  Thread-9 run 2 time(s)

  Thread-6 run 1 time(s)

  Thread-6 run 2 time(s)

  Thread-3 run 1 time(s)

  Thread-3 run 2 time(s)

  Create Thread-12

  Create Thread-13

  Create Thread-14

  Thread-12 run 1 time(s)

  Thread-12 run 2 time(s)

  Thread-13 run 1 time(s)

  Thread-13 run 2 time(s)

  Create Thread-15

  Thread-15 run 1 time(s)

  Thread-15 run 2 time(s)

  Create Thread-16

  Thread-16 run 1 time(s)

  Thread-16 run 2 time(s)

  Create Thread-17

  Create Thread-18

  Create Thread-19

  Thread-14 run 1 time(s)

  Thread-14 run 2 time(s)

  Thread-17 run 1 time(s)

  Thread-17 run 2 time(s)

  Thread-18 run 1 time(s)

  Thread-18 run 2 time(s)

  Thread-19 run 1 time(s)

  Thread-19 run 2 time(s)

  Thread-11 run 1 time(s)

  Thread-11 run 2 time(s)

转载: http://zhangjunhd.blog.51cto.com/113473/70068

分享到:
评论

相关推荐

    Java并发编程中使用Executors类创建和管理线程的

    Java提供了一套强大的并发工具,其中`java.util.concurrent.Executors`类是核心部分,它允许我们创建和管理线程池,极大地简化了并发编程。本篇将深入探讨`Executors`类的使用方法及其背后的并发原理。 `Executors`...

    Java多线程Executors批量执行数据实现限流

    Java多线程实现数据切割批量执行,实现限流操作。 java线程池Executors实现数据批量操作。 批量异步Executors处理数据,实现限流操作,QPS限流。 线程池调用第三方接口限流实现逻辑。 案例适合: 1.批量处理大数据。...

    线程池实例:使用Executors和ThreadPoolExecutor

    NULL 博文链接:https://bijian1013.iteye.com/blog/2284676

    java 线程池管理类:Executors_.docx

    `java.util.concurrent.Executors` 继承自 `java.lang.Object`,作为一个工具类,它提供了一系列用于创建和管理线程池的方法,包括`ExecutorService`、`ScheduledExecutorService`、`ThreadFactory`和`Callable`等...

    Java中Executors类中几种创建各类型线程池

    Java中Executors类中几种创建各类型线程池方法及简单实例

    Java并发编程中使用Executors类创建和管理线程的用法

    Java并发编程中,`java.util.concurrent.Executors` 类是一个至关重要的工具类,它提供了一系列静态方法,用于创建和管理线程池以及相关的线程执行服务。`Executors` 类简化了线程池的创建和线程的调度,使得开发者...

    java多线程的讲解和实战

    Java通过`Thread`类和`Runnable`接口来创建和管理线程。每个线程都有自己的生命周期,包括新建、就绪、运行、阻塞和结束五个状态。 2. **创建线程的方式**: - 继承`Thread`类:创建一个新的类,继承自`Thread`,...

    Java线程创建与管理:深入理解与实践指南

    Java语言提供了丰富的工具和技术来支持线程的创建和管理。本文将详细介绍Java中创建线程的不同方法,并探讨如何有效地管理线程的生命周期,以帮助读者更好地理解和应用Java多线程编程技术。 #### Java线程基础 在...

    什么是线程?Java中如何创建和管理线程?(java面试题附答案).txt

    ### Java中如何创建和管理线程 #### 创建线程的两种主要方式 1. **继承`Thread`类** 在Java中,可以通过继承`Thread`类来创建一个新的线程类。这种方式简单明了,但是会有一些局限性,因为Java不支持多重继承,...

    java 多线程的详细介绍和使用

    Java提供了多种创建和管理线程的方式,例如通过继承`Thread`类或实现`Runnable`接口。然而,线程的管理与同步是多线程编程中的一大挑战,因为线程间的竞争条件可能导致数据不一致,需要使用同步机制来避免。Java提供...

    java 线程池源代码

    Java线程池是一种高效管理线程的机制,它允许开发者预先创建一定数量的线程,然后根据需求将任务提交到线程池中进行执行。线程池的核心在于它能够有效地控制运行的线程数量,避免因为频繁创建和销毁线程而产生的性能...

    java线程实例 各种小Demo

    Java线程是多任务编程的重要概念,它允许程序同时执行多个独立的任务,从而...在"线程池.rar"和"线程实例"这两个文件中,你可以找到关于这些概念的具体示例代码,通过学习和实践,可以深入理解Java线程的运用和管理。

    Java线程使用教程

    1. **ExecutorService**:Java 5引入了`ExecutorService`接口,它是线程池的抽象,通过`Executors`工具类可创建各种类型的线程池。 2. **线程池类型**:`newFixedThreadPool`创建固定大小的线程池,`...

    java多线程查询数据库

    线程池可以有效地管理线程资源,避免频繁创建和销毁线程带来的开销。通过设置线程池的参数(核心线程数、最大线程数、线程存活时间等),我们可以控制并发程度和系统资源的利用率。 ### 3. 分页查询 在处理大量数据...

    每日练习:Java中的线程之线程间的通信教程.doc

    Java中的线程间通信是多线程...总的来说,Java中的线程通信和管理是多线程编程的关键,理解并掌握wait(), notify(), notifyAll()方法、ReentrantLock以及线程池的使用,能够帮助我们编写出更加高效、可控的并发程序。

    java并发编程:Executor、Executors、ExecutorService.docx

    Executor的主要目的是抽象出线程的创建和管理,让开发者只需关注任务本身,而无需关心线程的生命周期。传统的创建线程方式是通过`new Thread(new RunnableTask()).start()`,但使用Executor,可以通过`executor....

    Java+创建线程的例子源代码学习

    请确保按照说明正确解压文件,然后仔细阅读和分析源代码,理解每个类和方法的作用,以及它们如何协同工作来创建和管理线程。 在实践中,学习线程不仅包括创建和启动线程,还包括线程同步、线程通信(如`wait()`, `...

    Java多线程知识点总结

    线程池是一种多线程处理形式,它将线程和任务的概念分离开来,能够有效管理线程资源,减少线程创建和销毁的开销,提高程序性能。Java中可以通过Executors类快速创建线程池。 随着Java版本的更新,Java也引入了新的...

    线程池 Executors

    1. 降低资源消耗:频繁创建和销毁线程需要时间和资源,使用线程池可以重复使用线程,避免了频繁创建和销毁线程的开销。 2. 提高响应速度:线程池可以快速地响应任务的执行请求,因为线程池中的线程可以快速地被分配...

    java多线程示例

    本示例着重探讨如何在Java中实现和管理多线程,以及它带来的挑战和解决方案。 一、Java多线程基础 1. 创建线程: - 继承Thread类:创建一个新的类,继承自Thread类,重写其run()方法,然后创建该类的实例并调用...

Global site tag (gtag.js) - Google Analytics