标签:suspend 其他 xtend ima string 接口 call his pen
在Java中,如果要实现多线程,必须依靠一个线程的主体类(就好比主类的概念一样,表示的是一个线程的主类)。
但是这个线程的主体类在定义时也需要一些特殊的要求,即类需要继承Thread类或实现Runnable(Callable)接口来完成定义
public class MyThread extends Thread { //多线程的操作类 private String name ; public MyThread(String name) { this.name = name ; } @Override public void run() { //覆写run方法作为线程的主操作类 for(int x = 0 ; x <200 ;x++) { System.out.println(this.name+"-->"+x); } } } main: MyThread mt1 = new MyThread("线程A"); MyThread mt2 = new MyThread("线程B"); MyThread mt3 = new MyThread("线程C"); //启动多线程 mt1.start(); mt2.start(); mt3.start();
为什么多线程启动不是调用run()而必须调用start()?
在java的开发里面有一门技术称为Java本地接口(Java Native Interface,JNI)技术。使用Java调用本地操作系统提供的函数。
这个技术不能离开特定的操作系统,如果要执行线程,需要根据操作系统来进行资源的分配。主要是由JVM根据不同的操作系统来实现。
即使用Thread类的start()方法不仅要启动多线程的执行代码,还要根据不同的操作系统进行资源分配
public class MyThread2 implements Runnable { //实现接口 private String name ; public MyThread2(String name) { this.name = name ; } @Override public void run() { //覆写run() for(int x = 0 ; x <200 ;x++) { System.out.println(this.name+"-->"+x); } } }
main:
/***实现Runnable接口的多线程,,Thread是Runnable接口 的子类(代理),
* 通过Thread类对象包装Runnable接口对象实例,然后利用Thread 类的start()方法启动多线程***/
MyThread2 mt01 = new MyThread2("线程1");
MyThread2 mt02 = new MyThread2("线程2");
MyThread2 mt03 = new MyThread2("线程3");
new Thread(mt01).start();
new Thread(mt02).start();
new Thread(mt03).start();
使用Runnable接口可以有效避免单继承局限问题,所以在实际的开发中对于多线程的实现首选Runnable接口
public class Thread extends Object implements Runnable
通过定义可以发现,Thread类也是Runnable接口的子类,之前利用Runnable接口实现的多线程,实际结构:
Runnable接口 Thread类
class MyThread implements Runnable{ class MyThread extends Thread(){
@Override @Override
public void run(){//线程主方法 public void run(){ //线程主方法
//线程操作方法 //线程操作方法
} }
} }
MyThread mt = new MyThread(); MyThread mt = new MyThread();
new Thread(mt).start(); mt.start();
使用Runnable接口可以避免单继承的局限性,但是Runnable接口里面的run()方法不能返回操作结果。
从jdk1.5开始提供了新的接口: java.util.concurrent.Callable
@FunctionalInterface public interface Callable<V>{ public V call() throws Exception; }
public class MyThread implements Callable<String> { private int ticket = 0 ; @Override public String call() throws Exception { for(int i = 0 ; i <100; i ++) { if(this.ticket > 0) { System.out.println("卖出,剩余"+this.ticket --); } } return "票卖完了!"; //返回结果 } }
如何启动实现Callable接口的多线程?
Thread类没有定义构造方法可以直接接收Callble接口对象实例,并且由于需要接收call()方法返回值的问题。JDK1.5开始,提供了java.util.concurrent.FutureTask<V>类
public class FutureTask<V> extends Object implements RunnableFuture<V>
/***实现了callable 接口的多线程,可以返回结果;
* RunnableFuture接口 实现了Runnable接口和Future接口
* FutureTask 又实现了 RunnableFuture 接口
* ***/
MyThread mt1 = new MyThread();
MyThread mt2 = new MyThread();
FutureTask<String> task1 = new FutureTask<String>(mt1);
FutureTask<String> task2 = new FutureTask<String>(mt2);
//FutureTask是Runnable接口子类,所以可以使用Thread类的构造来接收task对象
new Thread(task1).start();
new Thread(task2).start();
//多线程执行完毕后可以取得内容
System.out.println("A线程的返回结果"+task1.get());
System.out.println("B线程的返回结果"+task2.get());
1.创建状态
在程序中用构造方法创建一个线程对象后,新的线程对象便处于新建状态。此时已经有相应内存空间和其他资源,但处于不可运行状态。
2.就绪状态
新建线程对象后,调用该线程的start()方法就可以启动线程。当线程启动时,线程进入就绪状态。此时线程将进入线程队列排队,等待cpu服务,这表明它已经具备了运行状态。
3.运行状态
当就绪状态的线程被调用并获得处理器资源时,线程就进入了运行状态。此时,自动调用该线程对象的run()方法。
4.堵塞状态
一个正在执行的线程在某些情况下,如被人为挂起或需要执行耗时的输入输出操作时,将让出CPU,并暂时中止自己的执行,进入堵塞状态。在可执行状态下,如果调用sleep()、suspend()、wait()等方法,线程都将进入堵塞状态。堵塞时,线程不能进入排队队列,只有当引起堵塞的原因被消除后,线程才可以转入就绪状态。
5.终止状态
线程调用stop()方法时候run()方法执行结束后,就处于终止状态。处于终止状态的线程不具有继续运行的能力
标签:suspend 其他 xtend ima string 接口 call his pen
原文地址:https://www.cnblogs.com/Thomas-blog/p/9735867.html