目录
程序线程进程
并发并行编辑
创建线程的基本方式
程序线程进程
并发并行
创建线程的基本方式（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("子线程结束");}
}
