多线程Thread,Runnable,Callable实现方式

这篇文章主要为大家详细介绍了Java多线程如何实现Thread,Runnable,Callable的方式，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

一、创建线程的常用三种方式

1、继承Thread类

创建MyThread 类并继承Thread

 package com.zrrd.XianCheng; /** *继承Thread类，达到线程的能力 */ public class MyThread extends Thread{ private String name; public MyThread(String name){ this.name=name; } @Override public void run() { for(int i=0;i<=100;i++){ System.out.println(name+"下载了"+i+"%"); } } }

创建测试类ThreadText 启动线程，执行代码块

 package com.zrrd.XianCheng; /** * 测试线程代码 */ public class ThreadText { public static void main(String[] args) { //创建一个线程对象 MyThread my=new MyThread( "A线程"); //启动线程start() my.start(); //创建第二个线程对象 MyThread my1=new MyThread("B线程"); //启动线程start() my1.start(); } }

执行结果图片，截取部分结果集

在这里插入图片描述

2、实现Runnable接口(重点)

以多个线程并发，解决方法为例

**创建BingFa 类并实现Runnable **

 package com.zrrd.XianCheng; /** * 多个线程并发，解决方法 */ public class BingFa implements Runnable { int piaoshu=50; Object obj=new Object(); @Override public void run() { /* 同步代码块用synchronized修饰*/ while (true){ synchronized (obj){//发生阻塞事件 if(piaoshu>0){ System.out.println(Thread.currentThread().getName()+"剩余"+(piaoshu--)+"张"); }else{ break; } } try { Thread.sleep(200); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.println(Thread.currentThread().getName()+"结束售票"); } }

创建测试类BingFaText启动线程，执行代码块

 package com.zrrd.XianCheng; import java.lang.Thread; public class BingFaText { public static void main(String[] args) { BingFa bf=new BingFa(); Thread th1=new Thread(bf,"售票窗口1"); Thread th2=new Thread(bf,"售票窗口2"); Thread th3=new Thread(bf,"售票窗口3"); Thread th4=new Thread(bf,"售票窗口4"); th1.start(); th2.start(); th3.start(); th4.start(); } }

执行结果图片，截取部分结果集

在这里插入图片描述

3、实现Callable接口（JDK1.5版本之后引入的）

创建MyCallable类并实现Callable

 package com.zrrd.XianCheng; import java.util.concurrent.Callable; public class MyCallable implements Callable {//多线程主体类 private int ticket=5;                     //线程共享资源 @Override public String call() throws Exception { for (int i=0;i<100;i++){ if(this.ticket>0){ System.out.println("卖票，ticket="+this.ticket--); } } return "票已卖光！";        //返回结果 } }

创建测试类MyCallableDemo启动线程，执行代码块

 package com.zrrd.XianCheng; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; public class MyCallableDemo { public static void main(String[] args) throws ExecutionException, InterruptedException { MyCallable callable1 = new MyCallable();//创建多线程实例1 MyCallable callable2 = new MyCallable();//创建多线程实例2 FutureTask task1 = new FutureTask(callable1); FutureTask task2 = new FutureTask(callable2); //FutureTask 是Runnable接口的子类，所以可以使用Thread类的构造方法来接收task对象 new Thread(task1).start(); new Thread(task2).start(); System.out.println("A______"+task1.get()); System.out.println("B______"+task2.get()); } }

执行结果图片

在这里插入图片描述