码迷,mamicode.com
首页 > 编程语言 > 详细

线程和线程池

时间:2019-10-25 11:45:00      阅读:73      评论:0      收藏:0      [点我收藏+]

标签:关闭   值类型   调用   匿名内部类   接口   exce   开始   inter   匿名   

一、Thread 类
  构造方法:Thread():创建新的线程
    Thread(String name):创建新的线程并指定改线程名
    Thread(Runnable runnable):创建新的线程并传入指定任务
  常用方法:对象.start():开始线程并执行任务
    run():要执行的任务
    sleep(long millis):暂停多少毫秒后执行
  实现过程:
    1、自定义类使之继承 Thread 类
    2、重写run()方法
    3、创建自定义类对象
    4、调用start()方法

  Demo:

  自定义类

1 public class MyThread extends Thread {
2     // run方法是用来描述线程任务的
3     @Override
4     public void run() {
5         for (int i = 0; i < 100; i++) {
6             System.out.println(getName() + ":" + i);
7         }
8     }
9 }

开启线程

1     public static void main(String[] args) {
2         MyThread mt = new MyThread();
3         // 开启线程
4         mt.start();
5         
6         for (int i = 0; i < 100; i++) {
7             System.out.println( Thread.currentThread().getName()+":"+ i);
8         }
9     }

 

 

二、Runnable 接口 (创建任务对象)
  好处:创建的任务对象,可以被多次执行,Thread 自定义类执行继承,继承的单一性,但是 Runnable 接口,可以实现多实现,不再单一。
  实现过程:
    1、自定义类使之实现 Runnable 接口
    2、重写Run 方法
    3、创建 自定义类的 对象
    4、创建 Thread 对象 并传入 指定任务对象 (自定义类对象)
    5、调用 Thread 的 start() 方法,使之开始执行任务

  Demo

  自定义类

  

1 public class MyRunnable implements Runnable {
2 
3     @Override
4     public void run() {
5         for (int i = 0; i < 100; i++) {
6             System.out.println(Thread.currentThread().getName() + ":" + i);
7         }
8     }
9 }

开启线程

 

 1 public static void main(String[] args) {
 2         Thread.currentThread().setName("System");
 3         // 创建线程任务对象
 4         MyRunnable mr = new MyRunnable();
 5                 //创建线程对象,并传入任务
 6         Thread t = new Thread(mr);
 7         t.setName("YHYThread");
 8                 //开启线程
 9         t.start();
10         for (int i = 0; i < 100; i++) {
11             System.out.println(Thread.currentThread().getName() + ":" + i);
12         }
13     }

 


三、使用匿名内部类来实现多线程
1、使用 Thread
    new Thread(){
      重写run 方法
    }.start();

    

1 new Thread(new Runnable() {
2             public void run() {
3                 Thread.currentThread().setName("YY");
4                 for (int i = 0; i < 100; i++) {
5                     System.out.println(Thread.currentThread().getName() + ":" + i);
6                 }
7             }
8         }).start();

    


2、使用 Runnable
    Runnable r = new Runnable(){
      重写run方法
    };
    Thread t = new Thread(r);
    t.start();

    

 1 public static void main(String[] args) {
 2         Runnable r= new Runnable() {            
 3             @Override
 4             public void run() {
 5                 System.out.println("任务");
 6             }
 7         };
 8         
 9         Thread t= new Thread(r);
10         t.start();
11     } 

 


四、线程池
  创建线程池对象:
    ExecutorService es = Executors.newFixedThreadPool(int nThreads);//传入需要开始线程的数量。

  使用Runnable 接口实现线程池
      1、创建Runnable的任务对象 并重写 run() 方法。
      2、获取线程池对象
      3、线程池对象.submit(Runnable task);//传入要执行的任务对象
      4、关闭线程池对象 线程池对象.shutdown();

      

 1     public static void main(String[] args) {
 2 //        指定任务对象,可以使用自定义类,实现Runnable接口
 3         Runnable r = new Runnable() {
 4             @Override
 5             public void run() {
 6                 System.out.println("任务");
 7             }
 8         };
 9 
10 //        获取线程池对象
11         ExecutorService es = Executors.newFixedThreadPool(2);
12 //        指定任务
13         es.submit(r);
14 //        关闭线程池
15         es.shutdown();
16     }

 

 

 

    使用 Callable 接口实现线程池
      1、创建 Callable 的任务对象,并重写 call() 方法。
      2、创建线程池对象
      3、线程池对象.submit(Callable c);//传入任务对象 (Callable 对象),假如有参数,使用Future<返回值类型> 接收
      4、获取返回值 Future<返回值类型>对象.get() 获取 call() 方法的返回值
      5、关闭线程池对象

      

 1     public static void main(String[] args) throws InterruptedException, ExecutionException {
 2 //        指定任务对象,并指定返回值,可以使用自定义类,实现Callable接口
 3         Callable<String> c = new Callable<String>() {
 4             @Override
 5             public String call() throws Exception {
 6 
 7                 return "aaa";
 8             }
 9         };
10 
11 //        获取线程池对象
12         ExecutorService es = Executors.newFixedThreadPool(2);
13 //        传入指定任务并使用 Future<V> 接收返回值
14         Future<String> submit = es.submit(c);
15 //        Future<V>对象 的 get() 方法接收返回值
16         String str = submit.get();
17         System.out.println(str);
18 //        关闭线程池
19         es.shutdown();
20     }

 

 

 

Callable 比Runable 的好处是:可以抛异常,可以有返回值

线程和线程池

标签:关闭   值类型   调用   匿名内部类   接口   exce   开始   inter   匿名   

原文地址:https://www.cnblogs.com/yanghaoyu0624/p/11737068.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!