wordpress网站入口今日网站收录查询
线程创建
通过Thread类创建
通过继承 Thread 类并重写run方法就可以实现多线程；在 Thread 类中 提供了start方法启动新线程
class MyThread extends Thread{public void run(){System.out.println("MyThread中的run方法已执行");}
}
public class Main{public static void main(String[] args) {MyThread t=new MyThread();Thread thread=new Thread(t);thread.start();}
}
通过Runnable接口创建
java只支持单继承，如果一个类继承了某个父类就没办法再继承 Thread 类了，因此，Thread类提供了另一种构造方法Thread (Runnable target)构传的参数实现了Runnable接口的对象，Runnable接口中只有一个run方法，创建线程时实现Runnable接口中的run方法作为运行代码，不需要再调用Thread类中的run方法。
class MyThread implements Runnable{public void run(){System.out.println("Runnable接口创建的线程已运行");}
}
public class Main{public static void main(String[] args){MyThread runnable=new MyThread();Thread thread=new Thread(runnable);thread.start();}
}通过Callable接口创建
在以上两种方法中创建线程的时候，里面的run方法都没有返回值，如果想要在run方法中获取返回值，就可以通过Callable接口来创建线程
import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;
import java.util.concurrent.ExecutionException;class MyThread4 implements Callable<Object>{@Overridepublic Object call() throws Exception {System.out.println("call方法已执行");return 0;}
}
class Main{public static void main(String[] args) throws ExecutionException, InterruptedException {MyThread4 mt=new MyThread4();FutureTask<Object> ft=new FutureTask<>(mt);Thread thread=new Thread(ft,"thread");thread.start();//获取返回值System.out.println(ft.get());}
}Callable 接口的实现的多线程是通过 FutureTask 类来进行封装和管理返回结果的，FutureTask 类的直接父接口是RunnableFuture，想必从名字我们就能看出它一定跟Runnable 接口有关系。RunnableFuture是Runnable和Future的结合体。看下图它们之间的关系：
在上图中我们可以看出，FutureTask是 Runnable 接口与 Future 接口的实现类。
线程创建的方式有多种，这里只列举了三种
其实严格来说，线程的创建方式只有通过new Thread().start()来创建，不管通过哪种方式最终都需要通过new Thread().start()创建。更加详细的描述可以看这篇文章大家都说Java有三种创建线程的方式！并发编程中的惊天骗局！
线程中断
线程中断指的是在线程运行过程中，手动中断线程的执行。
比如说，我写了一个多线程的代码，线程正在执行中，但是因为网速太辣鸡导致线程一直处于运行的状态，它不结束，我想停掉这个线程。
在 java 中执行线程中断有两个常用的方法：
- 通过共享的标记进行中断
- 使用 interrupt() 方法中断
第一种：
使用自定义的标志位
public class ThreadDemo {private static class MyRunnable implements Runnable{public volatile boolean isStop=false;public void run(){while(!isStop){System.out.println(Thread.currentThread().getName()+"正在加载中……");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}}public static void main(String[] args) throws InterruptedException {MyRunnable target=new MyRunnable();Thread thread=new Thread(target);thread.start();Thread.sleep(10*1000);target.isStop=true;System.out.println("线程已中断");}
}
第二种：
使用 Thread.interrupted() 或者 Thread.currentThread().isInterrupted() 代替自定义标志位
public void interrupt() 中断对象关联的线程，如果线程正阻塞，通过异常来通知，否则设置标志位
public class ThreadDemo{private static class MyRunnable implements Runnable{@Overridepublic void run(){while( !Thread.interrupted()){//或者 !Thread.interrupted()System.out.println(Thread.currentThread().getName()+"正在加载中……");try {Thread.sleep(1000);} catch (InterruptedException e) {System.out.println("线程已中断");break;}}}}public static void main(String[] args) throws InterruptedException {MyRunnable target=new MyRunnable();Thread thread=new Thread(target);thread.start();Thread.sleep(10*1000);thread.interrupt();}
}线程等待 -join()
有时候，我们想要在某个线程结束后再执行后面的任务，我们就需要线程等待，假如月光族张三想换个新手机，但是发现老板还没发工资，他就没钱买，只能等到老板发工资后再买
public class ThreadDemo3 {public static void main(String[] args) throws InterruptedException {Runnable runnable=()->{for(int i=0;i<10;i++){try {System.out.println(Thread.currentThread().getName()+"没钱！");Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}System.out.println(Thread.currentThread().getName()+"有钱了");};Thread thread1=new Thread(runnable,"老板");Thread thread2=new Thread(runnable,"张三");thread1.start();thread1.join();thread2.start();thread2.join();System.out.println("张三买到手机了");}
}
线程休眠
让线程休眠的方法如下：
- public static void sleep(long millis) throws InterruptedException 休眠当前线程millis毫秒
- public static void sleep(long millis,int nanos)throws InterruptedException 更高精度的休眠
public class ThreadDemo1 {public static void main(String[] args) throws InterruptedException {System.out.println("当前时刻："+System.currentTimeMillis());Thread.sleep(3000);System.out.println("当前时刻："+System.currentTimeMillis());}
}获取线程实例
我们可以通过以下的方法进行获取：
public static Thread currentThread();
public class ThreadDemo {public static void main(String[] args) {Thread thread=Thread.currentThread();System.out.println(thread);}
}