public class Runnable_test implements Runnable {//實(shí)現(xiàn)Runnable接口
private  int ticknumbers=10;

    @Override
    public void run() {
        while(true){
            if(ticknumbers<=0){
                break;
            }
            try {
                Thread.sleep(200);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName()+"-->拿到了第"+ticknumbers--+"票");//currentThread()監(jiān)測線程的狀態(tài)
        }
    }

    public static void main(String[] args) {
        Runnable_test runnable_test=new Runnable_test();
        new Thread(runnable_test,"小明").start();
        new Thread(runnable_test,"小黃").start();
        new Thread(runnable_test,"小紅").start();
    }
}

package Runnable;

public class Runnable_test implements Runnable {//實(shí)現(xiàn)Runnable接口
    private int ticknumbers = 20;
    private Object obj = new Object();//被加鎖的對象,同步對象

    @Override
    public void run() {
        while (true) {
            synchronized (obj) {
                if (ticknumbers > 0) {
                    System.out.println(Thread.currentThread().getName() + "-->拿到了第" + ticknumbers-- + "票");//currentThread()監(jiān)測線程的狀態(tài)
                    try {
                        Thread.sleep(300);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                } else
                    break;
            }
        }
    }
}


class test{
    public static void main(String[] args) {
        Runnable_test runnable_test=new Runnable_test();
        new Thread(runnable_test,"小明").start();
        new Thread(runnable_test,"小黃").start();
        new Thread(runnable_test,"小紅").start();
    }
}

package Runnable;

public class Runnable_test implements Runnable {//實(shí)現(xiàn)Runnable接口
    private int ticknumbers = 20;
    @Override
    public  void run() {
        while (true) {
            if (ticknumbers > 0) {
                ticks();//調(diào)用同步方法
            }
        else
            break;
        }
    }
    
    //同步方法
    public synchronized void ticks(){
        if (ticknumbers > 0) {
            System.out.println(Thread.currentThread().getName() + "-->拿到了第" + ticknumbers-- + "票");
            try {
                Thread.sleep(300);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

//測試類
class test{
    public static void main(String[] args) {
        Runnable_test runnable_test=new Runnable_test();
        new Thread(runnable_test,"小明").start();
        new Thread(runnable_test,"小黃").start();
        new Thread(runnable_test,"小紅").start();
    }
}

package Runnable;

public class Runnable_test implements Runnable {//實(shí)現(xiàn)Runnable接口
    private int ticknumbers = 20;
    boolean tag = false;//設(shè)置此變量的作用是為了讓一個(gè)線程進(jìn)入同步塊，另一個(gè)線程進(jìn)入同步方法

    @Override
    public void run() {
        if(tag){
            while(true)
                ticks();
        }
        else{
            while (true) {
                synchronized (this) {
                    if (ticknumbers > 0) {
                        System.out.println(Thread.currentThread().getName() + "-->拿到了第" + ticknumbers-- + "票");//currentThread()監(jiān)測線程的狀態(tài)
                        try {
                            Thread.sleep(300);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    } else
                        break;
                }
            }
        }
    }

    //同步方法
    public synchronized void ticks() {
        if (ticknumbers > 0) {
            System.out.println(Thread.currentThread().getName() + "-->拿到了第" + ticknumbers-- + "票");
            try {
                Thread.sleep(50);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        else
            return;
    }
}


    //測試類
    class test {
        public static void main(String[] args) throws InterruptedException {
            Runnable_test runnable_test = new Runnable_test();
            Thread thread1=new Thread(runnable_test, "小明");
            thread1.start();
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            runnable_test.tag=true;
            Thread thread2=new Thread(runnable_test, "小黃");
            thread2.start();
        }
    }

ThreadGroup myThreadGroup = new ThreadGroup("a");    //創(chuàng)建線程組

//將下述兩個(gè)線程加入其中
Thread myThread1 = new Thread(myThreadGroup,"worker1");
Thread myThread2 = new Thread(myThreadGroup,"worker2");
myThread1.start();
myThread2.start();

String getName();    //返回線程組的名字
ThreadGoup getParent();    //返回父線程
int tactiveCount();    //返回線程組中當(dāng)前激活的線程的數(shù)目，包括子線程組中的活動(dòng)線程
int enumerate(Thread list[])    //將所有線程組中激活的線程復(fù)制到一個(gè)線程數(shù)組中
void setMaxPriority(int pri)    //設(shè)置線程的最高優(yōu)先級，pri是該線程組的新優(yōu)先級
void interrupt()    //向線程組及其子組中的線程發(fā)送一個(gè)中斷信息
boolean isDaemon()    //判斷是否為Daemon線程組
boolean parentOf(ThreadGoup g)    //判斷線程組是否是線程g或g的子線程
toString()    //返回一個(gè)表示本線程組的字符串 

package Runnable;

public class MyThreadgroup {
    public void test(){
        ThreadGroup threadGroup=new ThreadGroup("test");    //創(chuàng)建名為test的線程組
        Thread A=new Thread(threadGroup,"線程A");
        Thread B=new Thread(threadGroup,"線程B");
        Thread C=new Thread(threadGroup,"線程C");

        //為線程設(shè)置優(yōu)先級
        A.setPriority(6);
        C.setPriority(4);
        A.start();
        B.start();
        C.start();
        System.out.println("threadGroup正在進(jìn)行活動(dòng)的個(gè)數(shù)："+threadGroup.activeCount());
        System.out.println("線程A的優(yōu)先級："+A.getPriority());
        System.out.println("線程B的優(yōu)先級："+B.getPriority());
        System.out.println("線程C的優(yōu)先級："+C.getPriority());
    }
}
class MyThreadgroup_test{
    public static void main(String[] args) {
       MyThreadgroup myThreadgroup=new MyThreadgroup();
       myThreadgroup.test();
    }
}

package Runnable;


 class Box {//產(chǎn)品緩沖區(qū)
    public String name="蘋果";//表示產(chǎn)品的名稱
    public boolean isFull=true;//表示當(dāng)前緩沖區(qū)中是否有產(chǎn)品
}



//定義消費(fèi)者類
class Cossumer implements Runnable {
    Box box;

    Cossumer(Box box) {
        this.box = box;
    }

    @Override
    public void run() {
        while (true) {
            synchronized (box) {//對產(chǎn)品緩沖區(qū)對象加鎖
                if (box.isFull == true) //緩沖區(qū)中有產(chǎn)品
                {
                    System.out.println("消費(fèi)者拿出----：" + box.name);
                    box.isFull = false;//設(shè)置緩沖區(qū)中產(chǎn)品為空
                    box.notify();//發(fā)送通知給生產(chǎn)者線程對象
                } else {
                    try {
                        //消費(fèi)者線程進(jìn)入產(chǎn)品緩沖區(qū)的等待隊(duì)列并釋放鎖
                        box.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
}



    //生產(chǎn)者類
    class product implements Runnable{
        Box box;
        int Count=0;

        public product(Box box) {
            this.box=box;
        }

        @Override
        public void run() {
            while(true){
                synchronized (box)//對產(chǎn)品緩沖區(qū)對象加鎖
                {
                    if(box.isFull==true)//緩沖區(qū)中有產(chǎn)品
                    {
                        try {
                            box.wait();//生產(chǎn)者線程進(jìn)入等待隊(duì)列并釋放鎖
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    else {
                        if (Count == 0) {
                            box.name = "香蕉";
                            System.out.println("生產(chǎn)者放入+++++：" + box.name);
                        } else {
                            box.name = "蘋果";
                            System.out.println("生產(chǎn)者放入+++++：" + box.name);
                        }
                        Count=(Count+1)%2;
                        box.isFull=true;//設(shè)置緩沖區(qū)中有產(chǎn)品
                        box.notify();//發(fā)送通知給消費(fèi)者線程對象
                    }
                }
            }
        }
    }


class box_test{
    public static void main(String[] args) {
        Box box=new Box();//創(chuàng)建產(chǎn)品緩沖區(qū)對象
        product product=new product(box);

        Cossumer cossumer=new Cossumer(box);//生產(chǎn)者和消費(fèi)者對象要共享同一個(gè)產(chǎn)品緩沖區(qū)
        Thread thread1=new Thread(product);//創(chuàng)建生產(chǎn)者線程對象
        Thread thread2=new Thread(cossumer);//創(chuàng)建消費(fèi)者線程對象
        thread1.start();//啟動(dòng)生產(chǎn)者線程對象
        thread2.start();//啟動(dòng)消費(fèi)者線程對象
    }
}