使用Callable接口创建线程和使用线程池的方式创建线程

 1 package com.baozi.java2;
 2 
 3 import java.util.concurrent.Callable;
 4 import java.util.concurrent.ExecutionException;
 5 import java.util.concurrent.FutureTask;
 6 
 7 public class ThreadNew {
 8     public static void main(String[] args){
 9         //3、创建callable接口实现类的对象
10         NewThread newThread= new NewThread();
11         //4、将此callable接口实现类的对象作为参数传递到FutureTask类的构造器中创建出一个FutureTask的实现类
12         FutureTask futureTask = new FutureTask(newThread);
13         //5、将FutureTask类的对象作为参数传递给Thread类的构造器创建一个Thread对象然后调用start()方法启动该线程
14         new Thread(futureTask).start();
15         try {
16             //6、可以通过futureTask.get()方法获取call()方法中的返回值
17             System.out.println(futureTask.get());
18         } catch (InterruptedException e) {
19             e.printStackTrace();
20         } catch (ExecutionException e) {
21             e.printStackTrace();
22         }
23     }
24 
25 }
26 //1、创建一个类实现callable接口
27 class NewThread implements Callable<Integer> {
28     //2、实现该接口中的call()方法
29     @Override
30     public Integer call() {
31         int sum = 0;
32         for (int i = 1; i <= 100; i++) {
33             if (i % 2 == 0) {
34                 sum += i;
35             }
36         }
37         return sum;
38     }
39 }

 1 package com.baozi.java2;
 2 
 3 import java.util.concurrent.ExecutorService;
 4 import java.util.concurrent.Executors;
 5 import java.util.concurrent.ThreadPoolExecutor;
 6 
 7 public class ThreadPool {
 8     public static void main(String[] args) {
 9         //1、先创建一个线程池
10         ExecutorService service = Executors.newFixedThreadPool(10);
11         //3、为线程池中线程分配任务并执行
12         ThreadPoolExecutor service1=(ThreadPoolExecutor)service;
13         System.out.println(service.getClass());
14         service.execute(new NumberThread1());
15         service.execute(new NumberThread2());
16         service.execute(new NumberThread3());
17         //4、关闭线程池
18         service.shutdown();
19     }
20 }
21 //2、创建要执行某种操作的线程
22 class NumberThread1 implements Runnable {
23     @Override
24     public void run() {
25         for (int i = 0; i <= 100; i++) {
26             if (i % 2 == 0) {
27                 System.out.println(Thread.currentThread().getName() + ":" + i);
28             }
29         }
30     }
31 }
32 
33 class NumberThread2 implements Runnable {
34     @Override
35     public void run() {
36         for (int i = 0; i <= 100; i++) {
37             if (i % 2 != 0) {
38                 System.out.println(Thread.currentThread().getName() + ":" + i);
39             }
40         }
41     }
42 }
43 
44 class NumberThread3 implements Runnable {
45     @Override
46     public void run() {
47         for (int i = 0; i <= 100; i++) {
48             System.out.println(Thread.currentThread().getName() + ":" + i);
49         }
50     }
51 }