Callable實現類介紹和函數式接口介紹

1:Callable實現類介紹

 

首先我們都知道，在Java中最常見的是繼承Thread類和實現Runnable接口來實現多線程（

 

這里我推薦采用實現接口的方式來實現多線程，原因有兩點：

 

1、Java的設計是單繼承的設計，如果采用繼承Thread的方式實現多線程，則不能繼承其他的類。

 

2、采用接口能夠更好的實現數據共享。線程的啟動需要Thread類的start方法，如果采用繼承的方式每次新建一個線程時，每個新建線程的數據都會單獨的存在線程內存中，這樣每個線程會單獨的操作自己線程的數據，不能更好的實現線程之間的數據共享）

 

但是無論以上哪種方式實現多線程，都存在一個問題，就是線程run方法沒有返回值，如果一個線程需要有返回值時，可以采用本章講的實現Callable接口來實現多線程

 

首先看一下Callable接口的源碼

@FunctionalInterface
public interface Callable<V> {
    /**
     * Computes a result, or throws an exception if unable to do so.
     *
     * @return computed result
     * @throws Exception if unable to compute a result
     */
    V call() throws Exception;
}

 

首先明確一點這是一個函數式接口，其中的@FunctionalInterface定義了這個接口為函數式接口（具體函數式接口和普通接口有何區別可以自行查閱相關資料） ，Callable接口接受一個泛型作為接口中call方法的返回值類型，因此我們在使用時需要傳入一個返回值類型。

 

然后我去實現這個接口來定義我自己的線程類，這里我傳入了一個String類型作為接口call方法的返回值類型，然后實現了call方法，將result作為返回結果返回

public class MyCallable<String> implements Callable<String> {
 
    private int tickt=10;
    
    @Override
    public String call() throws Exception {
        // TODO Auto-generated method stub
        String result;
        while(tickt>0) {
            System.out.println("票還剩余："+tickt);
            tickt--;
        }
        result=(String) "票已賣光";
        return result;
    }
 
}

下面就看一下怎樣啟動采用實現Callable接口的線程

package Multi_Thread;
import org.apache.commons.io.FileUtils;

import java.io.File;
import java.io.IOException;
import java.net.URL;
import java.util.concurrent.*;

/**
 * 實現callable接口
 */
public class CallMethod implements Callable<Boolean> {
    String url;
    String name;

    public CallMethod(String url, String name) {
        this.url = url;
        this.name = name;
    }

    @Override
    public Boolean call() {
        WebDownloader down = new WebDownloader();
        try {
            down.downloader(url,name);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return null;
    }
    class WebDownloader
    {
        public void downloader(String url,String name) throws IOException {
            FileUtils.copyURLToFile(new URL(url),new File(name));
        }
    }

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        CallMethod callMethod = new CallMethod("https://csdnimg.cn/medal/[e-mail]","a.png");
        //創建執行服務
        ExecutorService executorService = Executors.newFixedThreadPool(1);
        //提交執行
        Future<Boolean> submit = executorService.submit(callMethod);
        //獲取jieguo
        Boolean aBoolean = submit.get();
        System.out.println(aBoolean);
        executorService.shutdown();

    }
}

 

2:函數式接口

 

1. 函數式接口是個啥？

 

它是一個接口，在這個接口里面只能有一個抽象方法(但可以包含多個默認方法、靜態方法、繼承自Object的公有方法)。主要用於方法引用以及結合Lambda表達式使用。

 

2. 怎么定義？

 

@FunctionalInterface

public Interface MyFunction {
　　public void do();
　　//也可以包含如下方法
　　//默認方法
　　default void ddo() {
　　　　//do what you want
　　}
　　//靜態方法
　　public static void sdo() {
　　　　//do what you want
　　}
　　//繼承自Object的公有方法
　　@Override
　　public boolean equals(Object obj);
}
3. 怎么用？
public void main(String[] args) {
　　MyFunction mf = ()-> System.out.println("我是do方法");//l這個lambda表達式相當於實現了接口中的抽象方法，
　　mf.do();
}
輸出：
我是do方法

注意：JDK7及其以下版本JDK只能包含公開且抽象的方法（默認由public abstract修飾），而JDK8開始可以包含default、static修飾的非抽象方法。