使用Callable和Future創建線程

Java創建線程主要有三種方式：

　　1、繼承Thread類

　　2、實現Runnable接口

　　3、使用Callable和Future創建線程

 　  參考地址：https://www.cnblogs.com/yeya/p/10183366.html

一、繼承Thread類

步驟：

　　1、創建一個線程子類繼承Thread類

　　2、重寫run() 方法，把需要線程執行的程序放入run方法，線程啟動后方法里的程序就會運行

　　2、創建該類的實例，並調用對象的start()方法啟動線程

示例代碼如下：

public class ThreadDemo extends Thread{
    @Override
    public void run() {
        super.run();
        System.out.println("需要運行的程序。。。。。。。。");
    }

    public static void main(String[] args) {
        Thread thread = new ThreadDemo();
        thread.start();
    }
}

二、實現Runnable接口

　　1、定義一個線程類實現Runnable接口，並重寫該接口的run()方法，方法中依然是包含指定執行的程序。

　　2、創建一個Runnable實現類實例，將其作為target參數傳入，並創建Thread類實例。

　　3、調用Thread類實例的start()方法啟動線程。

示例代碼如下：

public class RunnableDemo implements Runnable{
    @Override
    public void run() {
        System.out.println("我是Runnable接口......");
    }
    public static void main(String[] args) {

        RunnableDemo demo = new RunnableDemo();
        Thread thread = new Thread(demo);
        thread.start();
    }
}

三、使用Callable和Future創建線程

使用Callable創建線程和Runnable接口方式創建線程比較相似，不同的是，Callable接口提供了一個call() 方法作為線程執行體，而Runnable接口提供的是run()方法，同時，call()方法可以有返回值，而且需要用FutureTask類來包裝Callable對象。

public interface Callable<V> {
    V call() throws Exception;
}

步驟：

　　1、創建Callable接口的實現類，實現call() 方法

　　2、創建Callable實現類實例，通過FutureTask類來包裝Callable對象，
　　　  該對象封裝了Callable對象的call()方法的返回值。

　　3、將創建的FutureTask對象作為target參數傳入，創建Thread線程實例並啟動新線程。

　　4、調用FutureTask對象的get方法獲取返回值。

示例代碼如下：

①.創建實現Callable接口的類

/**
 *<p> Description: 使用Callable與Future創建可會獲取返回值的線程 </p>
 *<p> Copyright: Copyright(c) 2018/12/27 </p>
 *<p> Company: xxx </p>
 *
 *@author Jason
 *@Version 1.0 2018/12/27 14:15
 */
public class ThreadUtil implements Callable {

    private StudentService studentService;

    public ThreadUtil() {
    }

    public ThreadUtil(StudentService studentService) {
        this.studentService = studentService;
    }

    /**
     * 重寫call()方法，查詢數據庫
     * @return List<Student>
     * @throws Exception 異常
     */
    @Override
    public List<Student> call() throws Exception {
        List<Student> students = studentService.allStudentsList();
        return students;
    }
}

②.測試開啟線程獲取線程返回的數據

/**
 *<p> Description: 線程測試類 </p>
 *<p> Copyright: Copyright(c) 2018/12/27 </p>
 *<p> Company: xxx </p>
 *
 *@author Jason
 *@Version 1.0 2018/12/27 14:22
 */
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class ThreadTest
{
    
    @Autowired
    private StudentService studentService;
    
    /**
     * 開啟線程查詢數據庫
     */
    @Test
    public void testThread1()
    {
        // 1.獲取FutureTask對象
        ThreadUtil threadUtil = new ThreadUtil(studentService);
        FutureTask futureTask = new FutureTask(threadUtil);
        
        // 2.開啟線程
        new Thread(futureTask).start();
        
        try
        {
           // 3.使用Futura#get()方法獲取線程的返回值
            List<Student> studentList = (List<Student>) futureTask.get();
            studentList.forEach(student -> System.out.println(student));
        }
        catch (InterruptedException e)
        {
            e.printStackTrace();
        }
        catch (ExecutionException e)
        {
            e.printStackTrace();
        }
    }
}