java 多線程

IamDLY 發(fā)布于2019-08-16 13:45 / 3453人閱讀

摘要：總結(jié)創(chuàng)建線程，方法運(yùn)行線程。創(chuàng)建線程使用繼承類實(shí)現(xiàn)創(chuàng)建線程文檔該類必須重寫方法。為新線程的入口點(diǎn)。中斷線程它表示一個(gè)線程被中斷，會(huì)拋出錯(cuò)誤。

java多線程

關(guān)于內(nèi)存

每個(gè)線程會(huì)有自己的線程棧，即，變量不能共享，只能傳值拷貝
每個(gè)線程new出的對(duì)象全都保存在堆中，全部共享

線程的生命周期

線程具有5種狀態(tài)，即新建，就緒，運(yùn)行，阻塞，死亡。
新建，當(dāng)new出來一個(gè)線程以后，jvm為其分配內(nèi)存空間，并初始化成員變量的值
就緒，當(dāng)線程調(diào)用了strat()方法的時(shí)候，線程就緒，會(huì)為其創(chuàng)建方法調(diào)用棧和程序計(jì)數(shù)器。

方法調(diào)用棧 即，記錄方法調(diào)用的次數(shù)
程序計(jì)數(shù)器 存放下一條單元指令的地方

運(yùn)行；就緒狀態(tài)獲得cpu，開始執(zhí)行run()方法
阻塞：例如進(jìn)入I/O操作

新建，就緒

使用new關(guān)鍵字創(chuàng)建一個(gè)線程以后，該線程處于新建狀態(tài)，和其他java線程一樣，僅僅由java虛擬機(jī)為其分配內(nèi)存，初始化變量成員的值。

運(yùn)行和阻塞 線程調(diào)度

桌面和服務(wù)器使用搶占式調(diào)度策略，小型設(shè)備使用協(xié)作式調(diào)度策略，

線程阻塞

線程使用sleep()方法主動(dòng)放棄所占用的處理器資源。
線程調(diào)用阻塞式I/O方法，方法被返回前，阻塞
線程等待通知
線程調(diào)用suspend()掛起

解除阻塞

依依對(duì)應(yīng)即可

線程優(yōu)先級(jí)

普通5，低1，高10
默認(rèn)是5

關(guān)于start和run

start創(chuàng)建一個(gè)線程，由于是時(shí)間片運(yùn)行的，所以需要run方法進(jìn)行運(yùn)行。
總結(jié)
start創(chuàng)建線程，run方法運(yùn)行線程。

創(chuàng)建線程 使用Thread繼承類實(shí)現(xiàn)創(chuàng)建線程

文檔 https://docs.oracle.com/javas...
該類必須重寫run方法。為新線程的入口點(diǎn)。
必須調(diào)用start()方法才能運(yùn)行。

本質(zhì)上是Runnable接口的一種實(shí)現(xiàn)

package demo2;

public class test {
    public static void main(String[] args) {
        // 創(chuàng)建一個(gè)線程
        ThreadDemo run1 = new ThreadDemo();
        run1.start();// 啟動(dòng)線程
        // 在運(yùn)行線程以后，會(huì)不定時(shí)的jvm調(diào)用run方法，進(jìn)行運(yùn)行
    }
}

package demo2;

public class ThreadDemo extends Thread{
    public ThreadDemo() {
        System.out.println("hello world");
    }
    
    public void run() {
        System.out.println("線程進(jìn)入");
        for(int i = 0; i > 10; i++) {
            System.out.println("輸出內(nèi)容");
        }
        System.out.println("線程執(zhí)行完畢");
    }
}

事實(shí)上父類的start方法也可以重寫

package demo2;

public class ThreadDemo extends Thread{
    public ThreadDemo() {
        System.out.println("hello world");
    }
    
    public void run() {
        System.out.println("線程進(jìn)入");
        for(int i = 0; i > 10; i++) {
            System.out.println("輸出內(nèi)容");
        }
        System.out.println("線程執(zhí)行完畢");
    }
    
    public void start() {
        System.out.println("啟動(dòng)線程");
        this.run();
    }
}

然后測(cè)試類

package demo2;

public class test {
    public static void main(String[] args) {
        // 創(chuàng)建一個(gè)線程
        ThreadDemo run1 = new ThreadDemo();
        run1.start();// 啟動(dòng)線程
    }
}

Thread方法 public final void setDaemon(boolean on)

用于標(biāo)記守護(hù)線程和用戶線程
用戶線程，平常創(chuàng)建的普通線程
守護(hù)線程，服務(wù)于用戶線程，不需要上層調(diào)用，例如gc垃圾回收為一個(gè)明顯的守護(hù)線程，mysql中也有執(zhí)行定時(shí)任務(wù)的線程。

中斷線程

它表示一個(gè)線程被中斷，會(huì)拋出錯(cuò)誤。

使用Runnable接口

文檔https://docs.oracle.com/javas...
屬于java.lang包內(nèi)的，為自動(dòng)默認(rèn)加載的
該接口具有一個(gè)run方法，run方法為程序的入口
必須通過Thread類的構(gòu)造方法實(shí)現(xiàn)啟動(dòng)線程

package demo2;

public class test {
    public static void main(String[] args) {
        // 創(chuàng)建一個(gè)線程
        demoRunnable r1 = new demoRunnable();
        // 使用Thread類的構(gòu)造方法傳入線程，并起名，然后運(yùn)行
        new Thread(r1, "name").start();// 創(chuàng)建完成線程以后，調(diào)用start啟動(dòng)線程
    }
}

package demo2;

public class demoRunnable implements Runnable{
    private int i;

    // 下方的為運(yùn)行的線程
    @Override
    public void run() {
        for(int i = 0; i < 100; i++) {
            System.out.println("運(yùn)行線程 " + i);
        }
    }
}

通過Callable和Future來創(chuàng)建線程

使用Callable創(chuàng)建接口的實(shí)現(xiàn)類
接口源碼如下

@FunctionalInterface
public interface Callable {
    V call() throws Exception;
}

實(shí)現(xiàn)了一個(gè)泛型，該并且返回該類型，需要實(shí)現(xiàn)call方法。使用包裝對(duì)象

關(guān)于包裝類型，即，將不是對(duì)象的內(nèi)容包裝成為對(duì)象，為包裝類型，實(shí)現(xiàn)了對(duì)象的類型，為一個(gè)類

先實(shí)現(xiàn)Callable接口，其中的call類為程序的子線程的執(zhí)行體

package demo2;

import java.util.concurrent.Callable;

public class CallableDemo implements Callable{
    @Override
    public Integer call() throws Exception {
        System.out.println("開始運(yùn)行一個(gè)線程");
        for(int i = 1, i < 10; i++) {
            System.out.println("運(yùn)行中");
        }
        // 阻塞該線程
        Thread.sleep(200);
        return 1;    // 返回線程的值
    }
}

接著創(chuàng)建Future對(duì)象，將用于啟動(dòng)子線程

package demo2;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

public class test {
    public static void main(String[] args) {
        // 先創(chuàng)建實(shí)例
        CallableDemo ctt = new CallableDemo();
        FutureTask ft = new FutureTask<>(ctt);    // 該方法為了獲取返回值而設(shè)定    
        new Thread(ft, "返回結(jié)果的值").start();
        try {
            System.out.println(ft.get());
        } catch (InterruptedException | ExecutionException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

package demo2;

import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;

public class CallableDemo implements Callable{
    @Override
    public Integer call() throws Exception {
        System.out.println("開始運(yùn)行一個(gè)線程");
        for(int i = 1; i < 10; i++) {
            System.out.println("運(yùn)行中");
        }
        return 1;    // 返回線程的值
    }
}