public class Demo01 {
    public static void main(String[] args) {
        //創(chuàng)建自定義線程對(duì)象
        MyThread mt = new MyThread("新的線程！");
        //開啟新線程
        mt.start();
        //在主方法中執(zhí)行for循環(huán)
        for (int i = 0; i < 10; i++) {
            System.out.println("main線程！"+i);
        }
    }
}
class MyThread extends Thread {
    //定義指定線程名稱的構(gòu)造方法
    public MyThread(String name) {
        //調(diào)用父類的String參數(shù)的構(gòu)造方法，指定線程的名稱 
        super(name);
    }
     //重寫run方法
    @Override
    public void run() {
        for (int i=0;i<100;i++)
        System.out.println(getName()+"：正在執(zhí)行！"+i);
    }
}

public class Demo2 {
    public static void main(String[] args) {
        //創(chuàng)建自定義類對(duì)象 線程任務(wù)對(duì)象
        MyRunnable mr = new MyRunnable();
        // 創(chuàng)建線程對(duì)象
        Thread t = new Thread(mr, "張三");
        t.start();
        for (int i = 0; i < 20; i++) {
            System.out.println("李四 " + i);
        }
    }
}
class MyRunnable implements Runnable{
    @Override public void run() {
        for (int i = 0; i < 20; i++) {
            System.out.println(Thread.currentThread().getName()+" "+i);
        }
    }
}

public class Demo3 {
    public static void main(String[] args) {
        new Thread(){
            @Override
            public void run() {
                for (int i = 0; i < 200; i++) {
                    System.out.println("張三 " + i);
                }
            }
        }.start();
        new Thread(){
            @Override
            public void run() {
                for (int i = 0; i < 200; i++) {
                    System.out.println("李四 " + i);
                }
            }
        }.start();
    }
}

public class Demo4 {
    public static void main(String[] args) {
        //創(chuàng)建線程任務(wù)對(duì)象
        Ticket ticket = new Ticket();
        //創(chuàng)建三個(gè)窗口對(duì)象 
        Thread t1 = new Thread(ticket, "窗口1"); 
        Thread t2 = new Thread(ticket, "窗口2"); 
        Thread t3 = new Thread(ticket, "窗口3"); 
        //同時(shí)賣票 
        t1.start(); 
        t2.start(); 
        t3.start();
    }
}
class Ticket implements Runnable {
    private int ticket = 1000;
    /** 執(zhí)行賣票操作 */
    @Override
    public void run() {
        //每個(gè)窗口賣票的操作
        // 窗口 永遠(yuǎn)開啟
        while (true) {
            if (ticket > 0) {
                //有票 可以賣 使用sleep模擬一下出票時(shí)間
                try {Thread.sleep(100);
                } catch (InterruptedException e) {
                    // TODO Auto‐generated catch block
                    e.printStackTrace();
                }
                //獲取當(dāng)前線程對(duì)象的名字
                String name = Thread.currentThread().getName();
                System.out.println(name + "正在賣:" + (ticket--));
            }
        }
    }
}

同步代碼塊
同步方法
鎖機(jī)制

synchronized( 同步鎖 ) { 
	需要同步操作的代碼 
}

public class Demo4 {
    public static void main(String[] args) {
        //創(chuàng)建線程任務(wù)對(duì)象
        Ticket ticket = new Ticket();
        //創(chuàng)建三個(gè)窗口對(duì)象
        Thread t1 = new Thread(ticket, "窗口1");
        Thread t2 = new Thread(ticket, "窗口2");
        Thread t3 = new Thread(ticket, "窗口3");
        //同時(shí)賣票
        t1.start();
        t2.start();
        t3.start();
    }
}
class Ticket implements Runnable {
    private int ticket = 100;
    /** 執(zhí)行賣票操作 */
    Object obj=new Object();
    @Override
    public void run() {
        //每個(gè)窗口賣票的操作
        // 窗口 永遠(yuǎn)開啟
        while (true) {
            synchronized (obj)
            {
                if (ticket > 0) {
                    //有票 可以賣 使用sleep模擬一下出票時(shí)間
                    try {Thread.sleep(500);
                    } catch (InterruptedException e) {
                        // TODO Auto‐generated catch block
                        e.printStackTrace();
                    }
                    //獲取當(dāng)前線程對(duì)象的名字
                    String name = Thread.currentThread().getName();
                    System.out.println(name + "正在賣:" + (ticket--));
                }
            }
        }
    }
}

public synchronized void method(){
	 可能會(huì)產(chǎn)生線程安全問題的代碼 
}

public class Demo5 {
    public static void main(String[] args) {
        //創(chuàng)建線程任務(wù)對(duì)象
        Ticket ticket = new Ticket();
        //創(chuàng)建三個(gè)窗口對(duì)象
        Thread t1 = new Thread(ticket, "窗口1");
        Thread t2 = new Thread(ticket, "窗口2");
        Thread t3 = new Thread(ticket, "窗口3");
        //同時(shí)賣票
        t1.start();
        t2.start();
        t3.start();
    }
}
class Ticket implements Runnable {
    private int ticket = 100;
    /**
     * 執(zhí)行賣票操作
     */
    Object obj = new Object();
    @Override
    public void run() {
        while (true)
        {
            sellticket();
        }
    }
    public synchronized void sellticket() {
        synchronized (obj) {
            if (ticket > 0) {
                //有票 可以賣 使用sleep模擬一下出票時(shí)間
                try {
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    // TODO Auto‐generated catch block
                    e.printStackTrace();
                }
                //獲取當(dāng)前線程對(duì)象的名字
                String name = Thread.currentThread().getName();
                System.out.println(name + "正在賣:" + (ticket--));
            }
        }
    }
}

import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class Demo6 {
    public static void main(String[] args) {
        //創(chuàng)建線程任務(wù)對(duì)象
        Ticket ticket = new Ticket();
        //創(chuàng)建三個(gè)窗口對(duì)象
        Thread t1 = new Thread(ticket, "窗口1");
        Thread t2 = new Thread(ticket, "窗口2");
        Thread t3 = new Thread(ticket, "窗口3");
        //同時(shí)賣票
        t1.start();
        t2.start();
        t3.start();
    }
}
class Ticket implements Runnable {
    private int ticket = 100;
    Lock lock=new ReentrantLock();
    @Override
    public void run() {
        //每個(gè)窗口賣票的操作
        // 窗口 永遠(yuǎn)開啟
        while (true) {
            lock.lock();
            if (ticket > 0) {
                //有票 可以賣 使用sleep模擬一下出票時(shí)間
                try {
                    Thread.sleep(50);
                } catch (InterruptedException e) {
                    // TODO Auto‐generated catch block
                    e.printStackTrace();
                }
                //獲取當(dāng)前線程對(duì)象的名字
                String name = Thread.currentThread().getName();
                System.out.println(name + "正在賣:" + (ticket--));
            }
            lock.unlock();
        }
    }
}

public class Demo7 {
    public static void main(String[] args) {
        baozi bz=new baozi();
        new baozipu(bz).start();
        new chihuo(bz).start();
    }
}
class baozi{
    String pi;
    String xian;
    boolean flag=false;
}
class baozipu extends Thread {
    private baozi bz;
    public baozipu(baozi bz) {
        this.bz=bz;
    }
    @Override
    public void run() {
        int count=0;
        while (true){
            synchronized(bz)
            {
                if(bz.flag)
                {
                    try {
                        bz.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                if(count%2==0){
                    //生產(chǎn) 大蝦餡包子
                    bz.pi = "薄皮";
                    bz.xian = "大蝦陷";
                }else{
                    //生產(chǎn) 冰皮 羊肉大蔥陷
                    bz.pi = "冰皮";
                    bz.xian = "羊肉大蔥陷";
                }
                count++;
                System.out.println("包子鋪正在生產(chǎn):"+bz.pi+bz.xian+"包子");
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                bz.flag=true;
                System.out.println("包子鋪已經(jīng)生產(chǎn)好了:"+bz.pi+bz.xian+"包子,吃貨可以開始吃了");
                bz.notify();
            }
        }
    }
}
class chihuo extends Thread{
    private baozi bz;
    public chihuo(baozi bz)
    {
        this.bz=bz;
    }
    @Override
    public void run() {
        while (true)
        {
            synchronized (bz){
                if (!bz.flag)
                {
                    try {
                        bz.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println("吃貨正在吃:"+bz.pi+bz.xian+"的包子");
                //吃貨吃完包子
                //修改包子的狀態(tài)為false沒有
                bz.flag = false;
                //吃貨喚醒包子鋪線程,生產(chǎn)包子
                bz.notify();
                System.out.println("吃貨已經(jīng)把:"+bz.pi+bz.xian+"的包子吃完了,包子鋪開始生產(chǎn)包子");
                System.out.println("----------------------------------------------------");
            }
        }
    }
}

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Demo8 {
    public static void main(String[] args) {
        ExecutorService es= Executors.newFixedThreadPool(3);
        MyRunable r=new MyRunable();
        es.submit(r);
        es.submit(r);
        es.submit(r);
        es.submit(r);
    }
}
class MyRunable implements Runnable{
    @Override
    public void run() {
        System.out.println("我是一個(gè)廚師，我去做飯了");
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("廚師做好飯了："+Thread.currentThread().getName());

    }
}