package com.asd.reserve.pojo.basic;

/**
 * @author zs
 * @date 2019/9/20 9:02
 */
public class MyThread  extends Thread{//【1】继承了Thread类，具有了多线程操作的能力
    //【2】重写run方法
    @Override
    public void run() {
        //【3】线程体  (为了让大家看到的运行效果更明显，使用循环)
        for (int i = 0; i <10; i++) {
            System.out.println("MyThread类中的i------------->"+i);
        }
    }
}

package com.asd.reserve.pojo.basic;

/**
 * @author zs
 * @date 2019/9/20 9:00
 */
public class TestMyThread {

    public static void main(String[] args) {
        //【1】创建多线程类MyThread的对象
        MyThread my=new MyThread();
        //【2】启动多线程
        my.start();//执行线程体,线程体写在了run方法中
        /**以下循环是主线程中的代码*/
        for (int i = 0; i <10; i++) {
            //System.out.println("main中的i===========================>"+i);
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + "中的" + i);
        }
    }
}

public class MyThread01 implements Runnable
{
    public void run()
    {
        for (int i = 0; i < 5; i++)
        {
            System.out.println(Thread.currentThread().getName() + "在运行!");
        }
    }
}

public static void main(String[] args)
{
    MyThread01 mt0 = new MyThread01();
    Thread t = new Thread(mt0);
    t.start();
        
    for (int i = 0; i < 5; i++)
    {
        System.out.println(Thread.currentThread().getName() + "在运行！");
    }
}

main在运行！
Thread-0在运行!
main在运行！
Thread-0在运行!
main在运行！
Thread-0在运行!
main在运行！
Thread-0在运行!
main在运行！
Thread-0在运行!

通过Thread实现线程：

//使用Thread实现线程不能实现资源共享  
class MyThread extends Thread  
{     
    private int ticket=5;  
    private String name;  
    public MyThread(String name ){  
        this.name=name;  
    }  
    public void run(){  
        for(int i=0;i<10;i++){  
            if(ticket>5){  
                System.out.println("线程"+name+"卖票"+i);  
            }  
        }  
      
    }  
}  
  
public class ThreadDemo02  
{  
    public static void main(String args[]){  
        MyThread A = new MyThread("A");    
        MyThread B = new MyThread("B");  
        A.start();  
        B.start();  
    }  
}  

通过Runnable实现：

//使用Runnable实现线程可以实现资源共享  
class MyThread implements Runnable  
{  
    private int ticket=5;  
    private String name;  
    public MyThread(String name){  
        this.name=name;  
    }  
    public void run(){  
        for(int i=1;i<=10;i++){  
            if(ticket>0){  
                System.out.println("线程"+name+"卖票"+(ticket--));  
                }  
        }  
    }  
}  
public class RunnableDemo02  
{  
    public static void main(String args[]){  
        MyThread A = new MyThread("A");  //实例化线程要执行的任务  
        Thread Ta = new Thread(A);    //实例两个线程对象，实际传递的是一个任务  
        Thread Tb = new Thread(A);    //因为两个线程执行的是一个任务，所以资源是共享的  
        Ta.start();  
        Tb.start();  
    }  
} 

 1 package com.asd.reserve.pojo.basic;
 2 
 3 /**
 4  * @author zs
 5  * @date 2019/9/20 12:00
 6  */
 7 public class SaleTicket implements Runnable{
 8 
 9     /*private int ticket=5;
10     @Override
11     public void run() {
12         for (int i = 0; i <100; i++) {//每个【窗口有100个人在排队
13 
14             sale();//调用本类中的同步方法sale()实现卖票
15 
16         }
17     }
18     public synchronized void sale(){//同步方法，加锁，给当前对象this加锁
19         //if开始
20         if (ticket>0) {
21             try {
22                 Thread.sleep(500);
23             } catch (InterruptedException e) {
24                 // TODO Auto-generated catch block
25                 e.printStackTrace();
26             }
27             System.out.println(Thread.currentThread().getName()+"卖第"+(ticket--)+"张票");
28 
29         }//if结束
30     }*/
31 
32 
33     private int ticket=5;
34     @Override
35     public void run() {
36         for (int i = 0; i <100; i++) {//每个【窗口有100个人在排队
37             //【1】同步代码块
38             synchronized (this) {
39                 //if开始
40                 if (ticket>0) {
41                     try {
42                         Thread.sleep(10);
43                     } catch (InterruptedException e) {
44                         // TODO Auto-generated catch block
45                         e.printStackTrace();
46                     }
47                     System.out.println(Thread.currentThread().getName()+"卖第"+(ticket--)+"张票");
48 
49                 }//if结束
50             }
51         }
52     }
53 }
54 
55 
56 
57 package com.asd.reserve.pojo.basic;
58 
59 /**
60  * @author zs
61  * @date 2019/9/20 12:03
62  */
63 public class SaleTicketTest {
64     public static void main(String[] args) {
65         //4个窗口
66         SaleTicket t1=new SaleTicket();
67         //【2】创建Thread类的对象
68         Thread t11=new Thread(t1,"我的线程1");
69         Thread t22=new Thread(t1,"我的线程2");
70         Thread t33=new Thread(t1,"我的线程3");
71         Thread t44=new Thread(t1,"我的线程4");
72 
73         //启动线程
74         t11.start();
75         t22.start();
76         t33.start();
77         t44.start();
78     }
79 }

 1 package com.asd.reserve.pojo.basic;
 2 
 3 /**
 4  * @author zs
 5  * @date 2019/9/20 10:13
 6  */
 7 public class MyTicketThread extends  Thread {
 8     private int ticket=5;//仅剩五张票
 9     public MyTicketThread(String threadName) {
10         super(threadName);//调用父类的带参构造方法
11     }
12 
13     @Override
14     public void run() {
15 
16 
17         // TODO Auto-generated method stub
18         for(int i=0;i<100;i++){
19             synchronized (this) {
20                 if(ticket>0){
21                     try {
22                         Thread.sleep(300);
23                     } catch (InterruptedException e) {
24                         // TODO Auto-generated catch block
25                         e.printStackTrace();
26                     }
27                     System.out.println(Thread.currentThread().getName() + "卖第"
28                             + (ticket--) + "张票");
29                 }
30             }
31         }
32     }
33 }
34 
35 
36 package com.asd.reserve.pojo.basic;
37 
38 import java.util.Random;
39 import java.util.concurrent.LinkedBlockingQueue;
40 import java.util.concurrent.RejectedExecutionHandler;
41 import java.util.concurrent.ThreadPoolExecutor;
42 import java.util.concurrent.TimeUnit;
43 
44 /**
45  * @author zs
46  * @date 2019/9/20 10:14
47  */
48 public class Test {
49     public static void main(String[] args) {
50         //4个窗口
51         MyTicketThread t1=new MyTicketThread("A窗口");
52         MyTicketThread t2=new MyTicketThread("B窗口");
53         MyTicketThread t3=new MyTicketThread("C窗口");
54         MyTicketThread t4=new MyTicketThread("D窗口");
55         //启动线程
56         t1.start();
57         t2.start();
58         t3.start();
59         t4.start();
60     }
61 }