package 多线程;/*** @author:yb* @version 创建时间：2018-12-24 下午4:14:16 类说明*/
/** 模拟龟兔赛跑 * 1.创建多线程：继承Thread+重写run()线程体* 2.使用线程：创建子类对象+对象调用start()*/
public class Rabbit extends Thread {// 线程体public void run() {for (int i = 1; i <= 100; i++) {System.out.println("兔子跑了" + i + "步");}}}
class Tortoise extends Thread {// 线程体public void run() {for (int i = 1; i <= 100; i++) {System.out.println("乌龟跑了" + i + "步");}}
}

package 多线程;/*** @author:yb* @version 创建时间：2018-12-24 下午4:20:53 类说明*/
public class RabbitApp {public static void main(String[] args) {// 创建子类对象Rabbit rab = new Rabbit();Tortoise tor = new Tortoise();// 调用start方法，不用调用run方法这个线程体
        rab.start();tor.start();/** 为什么输出会是兔子跑了两步乌龟才开始跑呢？* 因为是虚拟模拟实现的多线程，在底层cpu的按照时间片的轮转调度的，时间片先是给兔子这个对象* 它先跑两部，然后时间片时间到了，cpu把时间片给乌龟，然后乌龟开始跑* 实现的是虚拟的多线程（CPU轮流调度）* 如果是多核计算机的话，那才是真正的多线程2*/}}

package 多线程;/*** @author:yb* @version 创建时间：2018-12-25 下午7:05:34 类说明*/
/** 使用Runnabke创建线程*  1.类要实现Runnable接口+重写run方法体 -->真实角色*  2.创建多线程 使用静态代理的设计模式 *    1）创建真实角色*    2）创建代理角色+对真实角色的引用 *    3）调用start启动线程*/
public class Programmer implements Runnable {// 重写run方法体public void run() {for (int i = 0; i < 1000; i++) {System.out.println("第" + i + "次敲Hello world");}}
}

package 多线程;/*** @author:yb* @version 创建时间：2018-12-25 下午7:05:52 类说明*/
public class ProgrammerApp {public static void main(String[] args) {// 1）创建真实角色Programmer pro = new Programmer();// 2）创建代理角色+对真实角色的引用Thread proxy = new Thread(pro);// 3）调用start启动线程
        proxy.start();// 另外一个线程，因为main函数也算是一个线程for (int i = 0; i < 1000; i++) {System.out.println("第" + i + "次打开wegame");}}
}

package 多线程;/*** @author:yb* @version 创建时间：2018-12-25 下午7:36:44 类说明*//** 通过runnable接口实现多线程* 可以方便共享资源，同一份资源，多个代理访问* 代码背景：模拟人们在web12306上抢火车票* 共享的是num，票资源*/
public class Web12306 implements Runnable {// 100张火车票private int num = 50;// 重写run方法体public void run() {while (true) {if (num <= 0)break;System.out.println(Thread.currentThread().getName() + "抢到了火车票"+ num--);}}public static void main(String[] args) {// 真实角色Web12306 web12306 = new Web12306();// 代理角色1Thread t1 = new Thread(web12306, "顾客x");// 代理角色2Thread t2 = new Thread(web12306, "黄牛y");// 代理角色3Thread t3 = new Thread(web12306, "攻城狮z");// 启动线程
        t1.start();t2.start();t3.start();}}

package 多线程;import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;import org.omg.CORBA.INTERNAL;/*** @author:yb* @version 创建时间：2018-12-25 下午8:07:11 类说明*/
public class Call {/** 使用Callable创造线程*/public static void main(String[] args) throws InterruptedException, ExecutionException {// 创建线程池ExecutorService service = Executors.newFixedThreadPool(2);Race tortoise = new Race("乌龟",1000);Race rabbit = new Race("兔子", 500);Future<Integer> result1 = service.submit(tortoise);Future<Integer> result2 = service.submit(rabbit);Thread.sleep(3000);//主线程挂起3000ms 乌龟和兔子线程开始竞争cpu 即乌龟和兔子开始跑，跑的时间都是3000mstortoise.setFlag(false);rabbit.setFlag(false);//获取值int num1=result1.get();System.out.println("乌龟跑了"+num1+"步");int num2=result2.get();System.out.println("兔子跑了"+num2+"步");//停止服务
        service.shutdownNow();}}class Race implements Callable<Integer>{private String name;//名称private int time;//延时private int step=0;//步数public Race(String name,int time) {super();this.name=name;this.time=time;}private boolean flag= true;public int getTime() {return time;}public void setTime(int time) {this.time = time;}public boolean isFlag() {return flag;}public void setFlag(boolean flag) {this.flag = flag;}public int getStep() {return step;}public void setStep(int step) {this.step = step;}public String getName() {return name;}public void setName(String name) {this.name = name;}public Integer call() throws Exception{while(flag) {Thread.sleep(time);step++;    }return step;}
}