目录

程序线程进程

并发并行​编辑

创建线程的基本方式

---

程序线程进程

并发并行

创建线程的基本方式（1）

package com.edu.threaduse;public class Demo01 {public static void main(String[] args) throws InterruptedException {//创建Cat对象，可以当线程使用Cat cat = new Cat();cat.start();//启动线程//使用run的话是主线程里面的一个普通方法,只有run执行完毕才结束//说明:当main线程启动一个子线程Thread-0,主线程不会阻塞，会继续执行for (int i =0;i<10;i++){System.out.println("主线程i="+i);Thread.sleep(1000);}}
}
//通过继承Thread类创建线程
/*
当一个类继承类Thread类，该类就可以当做线程使用
我们会重写run方法，写上自己的业务代码
run Thread类实现Runnable接口的run方法*/
class Cat extends Thread{@Overridepublic void run() {int time =0;while(time++<80){//重写run方法，写上自己的业务逻辑//该线程每隔1秒，在控制台输出"喵喵，我是小猫咪";System.out.println("喵喵,我是小猫咪"+"线程名称="+Thread.currentThread().getName());//让线程休眠1stry {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

创建线程的基本方式（2） 

package com.edu.threaduse;public class Demo02 {public static void main(String[] args) {
//        Dog dog = new Dog();
//        //dog.start()无法使用
//        Thread thread = new Thread(dog);
//        thread.start();Tiger tiger = new Tiger();ThreadProxy threadProxy = new ThreadProxy(tiger);threadProxy.start();}
}
class Animal{}
class Tiger extends Animal implements Runnable{@Overridepublic void run() {System.out.println("老虎");}
}
class ThreadProxy implements Runnable{ //看成一个Thread代理类private  Runnable target = null;//属性@Overridepublic void run() {if(target!=null){target.run(); //运行类型为Tiger}}public ThreadProxy(Runnable target) {this.target = target;}public void start(){start0();}public void start0(){run();}
}class Dog implements Runnable{ //通过实现Runnable接口实现线程@Overridepublic void run() {while(true){System.out.println("小狗叫");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

售票超卖

package com.edu.ticket;public class SellTicket {public static void main(String[] args) {SellTick02 sellTick02 = new SellTick02();new Thread(sellTick02).start();new Thread(sellTick02).start();new Thread(sellTick02).start();}
}//class SellTick01 extends Thread{
//    private static int ticketNum = 100;
//
//    @Override
//    public void run() {
//
//       while (true){
//           if (ticketNum<=0){
//               System.out.println("售票结束");
//               break;
//           }
//           System.out.println("售出一张，还有:"+--ticketNum+"张");
//           try {
//               Thread.sleep(1000);
//           } catch (InterruptedException e) {
//               throw new RuntimeException(e);
//           }
//       }
//    }
//}
class SellTick02 implements Runnable{private  int ticketNum = 100;@Overridepublic void run() {while (true){if (ticketNum<=0){System.out.println("售票结束");break;}System.out.println("售出一张，还有:"+--ticketNum+"张");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

线程终止

package com.edu.exit;public class ThreadExit_ {public static void main(String[] args) throws InterruptedException {T t1 = new T();t1.start();//主线程休眠10s再通知Thread.sleep(10*1000);t1.setLoop(false);}
}
class T extends Thread{private  boolean loop = true;@Overridepublic void run() {while(loop){try {Thread.sleep(50);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("AThread 运行中...");}}//方便主线程控制public void setLoop(boolean loop) {this.loop = loop;}
}

 常用方法

package com.edu.method;public class ThreadMethod_ {public static void main(String[] args) throws InterruptedException {T t = new T();t.setName("老虎");t.setPriority(Thread.MIN_PRIORITY);System.out.println(t.getName());t.start();//主线程打印hi，然后中断子线程for (int i =0;i<5;i++){Thread.sleep(1000);System.out.println("HI");}t.interrupt(); //中断t的休眠}
}
class T extends Thread{@Overridepublic void run() {while (true){for (int i =0;i<100;i++){System.out.println(Thread.currentThread().getName()+"吃包子");}try {System.out.println(Thread.currentThread().getName()+"休眠中");Thread.sleep(20000);} catch (InterruptedException e) {//当线程执行道一个中断方法时，可以加入自己的业务代码System.out.println(Thread.currentThread().getName()+"被中断了");}}}}

package com.edu.method;public class ThreadMethod02 {public static void main(String[] args) throws InterruptedException {T1 t1 = new T1();t1.start();for (int i = 0;i<20;i++){if(i==5){Thread.yield();//t1.join}System.out.println("HI"+i);Thread.sleep(1000);}}
}
class T1 extends Thread{private int loop = 20;@Overridepublic void run() {while (loop-->0){System.out.println("Hello: "+loop);try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

package com.edu.method;public class ThreadMethod03 {public static void main(String[] args) throws InterruptedException {T3 t = new T3();Thread t1 = new Thread(t);for (int i = 1 ;i<=10;i++) {System.out.println("hi:"+i);if (i==5){t1.start();t1.join();}Thread.sleep(1000);}System.out.println("主进程结束");}
}
class T3 implements Runnable{@Overridepublic void run() {for (int i=1;i<=10;i++){System.out.println("HELLO:"+i);try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("子线程结束");}
}