线程创建
三种创建方式：
Thread class ->继承thread 类（重点）
Runnable 接口-> 实现Runnable接口(重点)
Callable接口->实现Callable接口(了解)
（一）、Thread
首先可以查看一下JDK帮助文档
步骤：继承Thread类，重写run方法，调用start()开启线程
//线程开启不一定立即执行，由cpu调度执行 public class TestThread1 extends Thread{ @Override public void run(){ //run方法线程体 for(int i = 0; i < 10; i++){ System.out.println("xx" + i); } } public static void main(String[] args){ //main线程， 主线程 //创建一个线程对象 TestThread1 testThread1 = new TestThread1(); //调用start()方法开启线程 testThread1.start(); for(int i = 0; i < 500; i++){ System.out.println("ss" + i); } } //开始执行后，不是说分开执行的，也不一定立即执行。 }
网图下载例子:实现多线程同步下载图片
public class TestThread2 extends Thread{ private String url; //图片地址 private String name; //保存的文件名 public TestThread2(String url, String name){ this.url = url; this.name = name; } @Override public void run(){ WebDownloader webDownloader = new WebDownloader(); webDownloader.downloader(url, name); System.out.println("下载文件名为：" + name); } public static void main(String[] args){ TestThread1 t1 = new TestThread1("",""); //两个参数一个为图片地址，一个为文件名例如2.jpg TestThread1 t2 = new TestThread1("",""); //两个参数一个为图片地址，一个为文件名例如2.jpg TestThread1 t3 = new TestThread1("",""); //两个参数一个为图片地址，一个为文件名例如2.jpg t1.start(); t2.start(); t3.start(); //每次运行的顺序会有所不同 } } //下载器 class WebDownloader{ //下载方法 public void downloader(String url,String name){ try{ FileUtils.copyURLToFile(new URL(url), new File(name)); }catch(IOException e){ e.printStackTrace(); System.out.println("IO异常,downloader方法有问题"); } } }
（二）、实现Runnable接口
推荐使用Runnable对象，因为java单继承的局限性
查看JDK帮助文档
步骤：继承MyRunnable类实现Runnable接口，重写run方法，编写执行体，创建线程对象调用start()开启线程
public class TestThread3 implements Runnable{ @Override public void run(){ //run方法线程体 for(int i = 0; i < 10; i++){ System.out.println("xx" + i); } } public static void main(String[] args){ //创建Runnable接口的实现类对象 TestThread3 testThread3 = new TestThread3(); //创建线程对象，通过线程对象来开启线程，代理。 Thread thread = new Thread(testThread3); thread.start(); //上面两行可以替换为 new Thread(testThread3).start(); for(int i = 0; i < 500; i++){ System.out.println("ss" + i); } } }
小结：
继承Thread类
- 子类继承Thread类具备多线程能力
- 启动线程：子类对象.start()
- 不建议使用：避免OOP单继承局限性
实现Runnable接口
- 实现接口Runnable具有多线程能力
- 启动线程：传入目标对象+Thread对象.start()
- 推荐使用：避免单继承局限性，灵活方便，方便同一个对象被多个线程使用
//一份资源 StartThread station = new StartThread(); //多个代理 new Thread(station,"小名").start(); new Thread(station,"小字").start();
例子：买票
/
import java.sql.SQLOutput; //多个线程同时操作同一个对象 //买火车票的例子 //发现了问题：多个线程操作同一个资源得情况下，线程不安全，数据紊乱 public class TestThread4 implements Runnable{ //票数 private int ticketNums = 10; @Override public void run() { while(true){ if(ticketNums <= 0){ break; } //如果数据较小可以通过模拟延迟 try { Thread.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "拿到了第" + ticketNums-- + "票"); } } public static void main(String[] args) { TestThread4 ticket = new TestThread4(); new Thread(ticket,"小名").start(); new Thread(ticket,"老师").start(); new Thread(ticket,"黄牛").start(); } }
例子：龟兔赛跑
//模拟龟兔赛跑 /* 1.首先来个赛道距离，然后要离终点越来越近 2.判断比赛是否结束 3.打印出胜利者 4.龟兔赛跑开始 5.乌龟要赢，兔子要睡觉，要模拟兔子要睡觉 6.最终乌龟赢得了比赛 */ public class Race implements Runnable{ //胜利者 private static String winner; @Override public void run() { for (int i = 0; i <= 100; i++) { //模拟兔子休息 if(Thread.currentThread().getName().equals("兔子") && i % 10 == 0){ try { Thread.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); } } //判断比赛是否结束 boolean flag = gameOver(i); //如果比赛结束了就停止程序 if(flag){ break; } System.out.println(Thread.currentThread().getName()+"跑了"+i+"步"); } } //判断是否完成比赛 private boolean gameOver(int steps){ //判断是否有胜利者 if(winner != null){ return true; }else if(steps >= 100){ winner = Thread.currentThread().getName(); System.out.println("Winner is" + winner); return true; } return false; } public static void main(String[] args) { Race race = new Race(); new Thread(race,"兔子").start(); new Thread(race,"乌龟").start(); } }
（三）、实现Callable接口（了解扩充）
- 实现Callable接口，需要返回值类型
- 重写call方法，需要抛出异常
- 创建目标对象
- 创建执行服务：ExecutorService ser = Executors.newFixedThreadPool(1);
- 提交执行：Future result1 = ser.submit(t1);
- 获取结果：boolean r1 = result1.get()
- 关闭服务：ser.shutdownNow();
///
/* Callable的好处 1.可以定义返回值 2.可以抛出异常 */ public class TestCallable implements Callable<Boolean> { private String url; //图片地址 private String name; //保存的文件名 public TestCallable(String url, String name){ this.url = url; this.name = name; } @Override public Boolean call(){ WebDownloader webDownloader = new WebDownloader(); webDownloader.downloader(url, name); System.out.println("下载文件名为：" + name); return true; } public static void main(String[] args) throws ExecutionException, InterruptedException { TestCallable t1 = new TestCallable("gh","cvx"); //两个参数一个为图片地址，一个为文件名例如2.jpg TestCallable t2 = new TestCallable("cvx","xcv"); //两个参数一个为图片地址，一个为文件名例如2.jpg TestCallable t3 = new TestCallable("vcx","vcx"); //两个参数一个为图片地址，一个为文件名例如2.jpg //创建执行服务 ExecutorService ser = Executors.newFixedThreadPool(3); //提交执行 Future<Boolean> result1 = ser.submit(t1); Future<Boolean> result2 = ser.submit(t2); Future<Boolean> result3 = ser.submit(t3); //获取结果 boolean r1 = result1.get(); boolean r2 = result2.get(); boolean r3 = result3.get(); System.out.println(r1); System.out.println(r2); System.out.println(r3); //关闭服务 ser.shutdownNow(); } } //下载器 class WebDownloader{ //下载方法 public void downloader(String url,String name){ try{ FileUtils.copyURLToFile(new URL(url), new File(name)); }catch(IOException e){ e.printStackTrace(); System.out.println("IO异常,downloader方法有问题"); } } }
（四）、静态代理
/* 静态代理模式总结: 真实对象和代理对象都要实现同一个接口 代理对象要代理真实角色 */ /* 好处： 代理对象可以做很多真实对象做不了的事情 真实对象专注做自己的事情 */ public class StaticProxy { public static void main(String[] args) { You you = new You(); // 代理 真实对象（Runnable接口。这个是thread里的） 调用方法 // new Thread( ()-> System.out.println("wowoow")).start(); //运用了lamda表达式 ，和下面两个可以结合学习 // new WeddingCompany(new You()).HappyMarry(); //这一行可以代替下面两行 WeddingCompany weddingCompany= new WeddingCompany(you); weddingCompany.HappyMarry(); } } interface Marry{ void HappyMarry(); } class You implements Marry{ @Override public void HappyMarry() { System.out.println("结婚了"); } } //代理角色，帮助你结婚 class WeddingCompany implements Marry{ //代理谁-->真实目标角色 private Marry target; public WeddingCompany(Marry target) { this.target = target; } @Override public void HappyMarry() { before(); this.target.HappyMarry();//这就是真实的对象 after(); } private void after() { System.out.println("结婚之后收尾款"); } private void before() { System.out.println("结婚之前布置现场"); } }
