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

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

目录一、创建线程的常用三种方式1、继承Thread类2、实现Runnable接口(重点)以多个线程并发，解决方法为例3、 实现Callable接口（JDK1.5版本之后引入的）总结

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

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();

}

}

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

http://

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){

http:// 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());

}

}

执行结果图片

总结

以上就是实现多线程的方式，在实际开发项目中不建议使用第一种继承Thread方式实现线程，这样对代码的侵入性太高，而且类与类之间单继承，达不到代码重用规则，建议使用第二种、或第三种。

本篇文章就到这里了，希望能给你带来帮助，也希望您能够多多关注我们的更多内容！

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。