【Java】【Thread多線程】概述

多線程概述

  1. 通過子類繼承開啟多線程 
    public class Demo {
    public static void main(String[] args) throws IOException {
    MyThread myThread = new MyThread();
    myThread.start();
    
    for(int i = 0;i<1000;i++){
        System.out.print("b");
    }
}
}

class MyThread extends Thread {
    public void run() {
        for (int i = 0; i < 1000; i++) {
            System.out.print("a");
        }
    }
}
  2. 通過實(shí)現(xiàn)Runnable接口開啟多線程 
    public class Demo {
    public static void main(String[] args) throws IOException {
        MyThread myThread = new MyThread();
        Thread t = new Thread(myThread);
        t.start();
        
        for (int i = 0; i < 1000; i++) {
            System.out.print("b");
        }
    }
}

class MyThread implements Runnable {
    @Override
    public void run() {
        for (int i = 0; i < 1000; i++) {
            System.out.print("a");
        }
    }
}
  3. 通過匿名內(nèi)部類實(shí)現(xiàn)多線程 
    // 方法1
public static void main(String[] args) throws IOException {
    new Thread(){
        @Override
        public void run() {
            for(int i = 0;i<1000;i++){
                System.out.print("a");
            }
        }
    }.start();
    for(int i = 0;i<1000;i++){
        System.out.print("b");
    }
}
// 方法2
public static void main(String[] args) throws IOException {
    new Thread(new Runnable() {
        @Override
        public void run() {
            for (int i = 0; i < 1000; i++) {
                System.out.print("a");
            }
        }
    }) {
    }.start();
    for (int i = 0; i < 1000; i++) {
        System.out.print("b");
    }
}
  4. 設(shè)置和獲取線程名稱(setName&getName) 
    public class Demo {
    public static void main(String[] args) throws IOException {
        new Thread("subThread A") { // 通過構(gòu)造方法修改名稱
            @Override
            public void run() {
                for (int i = 0; i < 1000; i++) {
                    System.out.println(this.getName());
                }
            }
        }.start();
        
        new Thread() {
            @Override
            public void run() {
                this.setName("subThread B"); // 通過setName方法 修改線程名稱
                for (int i = 0; i < 1000; i++) {
                    System.out.println(this.getName());
                }
            }
        }.start();
    }
}
  5. 獲取當(dāng)前線程對(duì)象(Thread.currentThread) 
    public class Demo {
    public static void main(String[] args) throws IOException {
        new Thread("subThread A") { // 通過構(gòu)造方法修改名稱
            @Override
            public void run() {
                for (int i = 0; i < 1000; i++) {
                    System.out.println(this.getName());
                }
            }
        }.start();
        
        new Thread(new Runnable() {
            @Override
            public void run() {
                for (int i = 0; i < 1000; i++) {
                    System.out.print(Thread.currentThread().getName()); // 通過Runnable方法實(shí)現(xiàn)的多線程，無法通過this獲取Thread類對(duì)象，只能通過Thread.currentThread獲取當(dāng)前線程
                }
            }
        }) {
        }.start();
        
        // 通過Thread.currentThread方法獲取和設(shè)置主線程屬性
        Thread.currentThread().setName("我是主線程");
        System.out.println(Thread.currentThread().getName());
    }
}
  6. 線程休眠(sleep) 
    public class Demo {
    public static void main(String[] args) throws IOException {
        new Thread() {
            @Override
            public void run() {
                for (int i = 0; i < 10; i++) {
                    System.out.println(new MyDatetime(System.currentTimeMillis()).getCn());
                    try { // 每次線程執(zhí)行一次則休眠一秒
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }.start();
    }
}
  7. 守護(hù)線程(setDaemon) 
    public class Demo {
    public static void main(String[] args) throws IOException {
        Thread t1 = new Thread() { // 這里是守護(hù)線程
            @Override
            public void run() {
                for (int i = 0; i < 1000; i++) {
                    System.out.print("a"); // 執(zhí)行1000次打印
                }
            }
        };
        
        Thread t2 = new Thread() {
            @Override
            public void run() {
                for (int i = 0; i < 5; i++) {
                    System.out.print("b"); // 執(zhí)行5次打印
                }
            }
        };
        
        t1.setDaemon(true);
        
        t1.start();
        t2.start();
        // 結(jié)論：當(dāng)正常線程結(jié)束后，守護(hù)線程跟隨停止
    }
}
  8. 加入線程(join) 
    public class Demo {
    public static void main(String[] args) throws IOException {
        final Thread t1 = new Thread() { // 匿名內(nèi)部類在使用其方法的時(shí)候需要使用final修飾
            @Override
            public void run() {
                for (int i = 0; i < 10; i++) {
                    System.out.print("a");
                    try {
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        };
        Thread t2 = new Thread() {
            @Override
            public void run() {
                for (int i = 0; i < 10; i++) {
                    if (i == 2) {
                        try {
                            t1.join();
                            Thread.sleep(10);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    System.out.print("b");
                }
            }
        };
        t1.start();
        t2.start();
        // 執(zhí)行結(jié)果：abbaaaaaaaaabbbbbbb
    }
}

public class Demo {
    public static void main(String[] args) throws IOException {
        final Thread t1 = new Thread() { // 匿名內(nèi)部類在使用其方法的時(shí)候需要使用final修飾
            @Override
            public void run() {
                for (int i = 0; i < 10; i++) {
                    System.out.print("a");
                    try {
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        };
        Thread t2 = new Thread() {
            @Override
            public void run() {
                for (int i = 0; i < 10; i++) {
                    if (i == 2) {
                        try {
                            t1.join(10); // 當(dāng)b線程執(zhí)行完成后，交還給a執(zhí)行10毫秒，再次交替執(zhí)行
                            Thread.sleep(10);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    System.out.print("b");
                }
            }
        };
        t1.start();
        t2.start();
        // 執(zhí)行結(jié)果：abbaabbbbbbbbaaaaaaa
    }
}
  9. 同步代碼塊(synchronized) 
    public class Demo {
    public static void main(String[] args) throws IOException {
        final Person person = new Person();
        new Thread() {
            @Override
            public void run() {
                for (int i = 0; i <= 100; i++) {
                    person.printNum();
                    System.out.println();
                }
            }
        }.start();
        new Thread() {
            @Override
            public void run() {
                for (int i = 0; i < 100; i++) {
                    person.printLetter();
                    System.out.println();
                }
            }
        }.start();
    }
}

class Person {
    public void printNum() {
        // 強(qiáng)制程序執(zhí)行時(shí)，執(zhí)行該代碼塊完全執(zhí)行后，再跳轉(zhuǎn)其他線程。同步代碼塊
        synchronized (this) {
            System.out.print("1");
            System.out.print("2");
            System.out.print("3");
            System.out.print("4");
            System.out.print("5");
        }
    }
    
    public void printLetter() {
        synchronized (this) {
            System.out.print("a");
            System.out.print("b");
            System.out.print("c");
            System.out.print("d");
            System.out.print("e");
        }
    }
}
  10. 同步方法 
    public class Demo {
    public static void main(String[] args) throws IOException {
        final Person person = new Person();
        new Thread() {
            @Override
            public void run() {
                for (int i = 0; i <= 100; i++) {
                    person.printNum();
                    System.out.println();
                }
            }
        }.start();
        new Thread() {
            @Override
            public void run() {
                for (int i = 0; i < 100; i++) {
                    person.printLetter();
                    System.out.println();
                }
            }
        }.start();
    }
}

class Person {
// 同步方法
    public synchronized void printNum() {
        System.out.print("1");
        System.out.print("2");
        System.out.print("3");
        System.out.print("4");
        System.out.print("5");
    }
    
    public void printLetter() {
        synchronized (this) {
            System.out.print("a");
            System.out.print("b");
            System.out.print("c");
            System.out.print("d");
            System.out.print("e");
        }
    }

// 靜態(tài)同步方法
    public static synchronized void printNum2() {
        System.out.print("1");
        System.out.print("2");
        System.out.print("3");
        System.out.print("4");
        System.out.print("5");
    }
    
    public static void printLetter2() {
        synchronized (Person.class) {
            System.out.print("a");
            System.out.print("b");
            System.out.print("c");
            System.out.print("d");
            System.out.print("e");
        }
    }
}
  11. 多線程安全 
    public class Demo {
    public static void main(String[] args) throws IOException {
        // 同時(shí)打開4個(gè)售票窗口進(jìn)行售票
        new Ticket().start();
        new Ticket().start();
        new Ticket().start();
        new Ticket().start();
    }
}

// 售票窗口
class Ticket extends Thread {
    private static int ticket = 100;
    
    @Override
    public void run() {
        while (true) {
            synchronized (Ticket.class) { // 必須使用靜態(tài)
                if (ticket <= 0) {
                    // 防止出現(xiàn)0號(hào)或負(fù)號(hào)票
                    break;
                }
                try {
                    Thread.sleep(10);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("第" + ticket-- + "張票");
            }
        }
    }
}
  12. 多線程安全（死鎖） 
    public class Demo {

    private static String s1 = "《筷子左》";
    private static String s2 = "《筷子右》";
    
    public static void main(String[] args) throws IOException {
        // 使用者1
        new Thread("使用者1") {
            @Override
            public void run() {
                while(true){
                    synchronized (s1) {
                        System.out.println(this.getName() + "：拿到" + s1 + "等待" + s2);
                        synchronized (s2) {
                            System.out.println(this.getName() + "：拿到" + s2 + "開吃");
                        }
                    }
                }
            }
        }.start();
        
        // 使用者2
        new Thread("使用者2") {
            @Override
            public void run() {
                while(true){
                    synchronized (s2) {
                        System.out.println(this.getName() + "：拿到" + s2 + "等待" + s1);
                        synchronized (s1) {
                            System.out.println(this.getName() + "：拿到" + s1 + "開吃");
                        }
                    }
                }
            }
        }.start();
    }
}
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • 1. Java基礎(chǔ)部分 基礎(chǔ)部分的順序：基本語法，類相關(guān)的語法，內(nèi)部類的語法，繼承相關(guān)的語法，異常的語法，線程的語...
    子非魚_t_閱讀 34,612評(píng)論 18贊 399
  • 一、 1、請(qǐng)用Java寫一個(gè)冒泡排序方法 【參考答案】 public static void Bubble(int...
    獨(dú)云閱讀 1,493評(píng)論 0贊 6
  • 本文主要講了java中多線程的使用方法、線程同步、線程數(shù)據(jù)傳遞、線程狀態(tài)及相應(yīng)的一些線程函數(shù)用法、概述等。 首先講...
    李欣陽閱讀 2,584評(píng)論 1贊 15
  • 爬上樹的魚兒閱讀 231評(píng)論 0贊 0
  • 我到達(dá)馬德里的那天夜晚，正好趕上了萬圣之夜。我倒沒有刻意算過日子，直到看到街頭巷尾到處可見的靈異裝扮，才提醒了我這...
    索萊耶閱讀 804評(píng)論 2贊 21

友情鏈接更多精彩內(nèi)容