Java创建线程的四种方式

 

1.继承Thread类实现多线程

    run()为线程类的核心方法,相当于主线程的main方法,是每个线程的入口
    a.一个线程调用 两次start()方法将会抛出线程状态异常,也就是的start()只可以被调用一次 
    b.native生明的方法只有方法名,没有方法体。是本地方法,不是抽象方法,而是调用c语言方法
      registerNative()方法包含了所有与线程相关的操作系统方法
    c. run()方法是由jvm创建完本地操作系统级线程后回调的方法,不可以手动调用(否则就是普通方法)

 
  1. public class MyThread extends Thread {

  2. public MyThread() {

  3.  
  4. }

  5. public void run() {

  6. for(int i=0;i<10;i++) {

  7. System.out.println(Thread.currentThread()+":"+i);

  8. }

  9. }

  10. public static void main(String[] args) {

  11. MyThread mThread1=new MyThread();

  12. MyThread mThread2=new MyThread();

  13. MyThread myThread3=new MyThread();

  14. mThread1.start();

  15. mThread2.start();

  16. myThread3.start();

  17. }

  18. }

2.覆写Runnable()接口实现多线程,而后同样覆写run().推荐此方式

    a.覆写Runnable接口实现多线程可以避免单继承局限
    b.当子类实现Runnable接口,此时子类和Thread的代理模式(子类负责真是业务的操作,thread负责资源调度与线程创建辅助真实业务。

 
  1. public class MyThread implements Runnable{

  2. public static int count=20;

  3. public void run() {

  4. while(count>0) {

  5. try {

  6. Thread.sleep(200);

  7. } catch (InterruptedException e) {

  8. e.printStackTrace();

  9. }

  10. System.out.println(Thread.currentThread().getName()+"-当前剩余票数:"+count--);

  11. }

  12. }

  13. public static void main(String[] args) {

  14. MyThread Thread1=new MyThread();

  15. Thread mThread1=new Thread(Thread1,"线程1");

  16. Thread mThread2=new Thread(Thread1,"线程2");

  17. Thread mThread3=new Thread(Thread1,"线程3");

  18. mThread1.start();

  19. mThread2.start();

  20. myThread3.start();

  21. }

  22. }

继承Thread和实现Runnable接口的区别

    a.实现Runnable接口避免多继承局限
    b.实现Runnable()可以更好的体现共享的概念

3.覆写Callable接口实现多线程(JDK1.5)

    a.核心方法叫call()方法,有返回值
    b.有返回值

 
  1. import java.util.concurrent.Callable;

  2. import java.util.concurrent.ExecutionException;

  3. import java.util.concurrent.FutureTask;

  4.  
  5. public class MyThread implements Callable<String> {

  6. private int count = 20;

  7.  
  8. @Override

  9. public String call() throws Exception {

  10. for (int i = count; i > 0; i--) {

  11. // Thread.yield();

  12. System.out.println(Thread.currentThread().getName()+"当前票数:" + i);

  13. }

  14. return "sale out";

  15. }

  16.  
  17. public static void main(String[] args) throws InterruptedException, ExecutionException {

  18. Callable<String> callable =new MyThread();

  19. FutureTask <String>futureTask=new FutureTask<>(callable);

  20. Thread mThread=new Thread(futureTask);

  21. Thread mThread2=new Thread(futureTask);

  22. Thread mThread3=new Thread(futureTask);

  23. // mThread.setName("hhh");

  24. mThread.start();

  25. mThread2.start();

  26. mThread3.start();

  27. System.out.println(futureTask.get());

  28.  
  29. }

  30. }

4.通过线程池启动多线程

通过Executor 的工具类可以创建三种类型的普通线程池:

 

FixThreadPool(int n); 固定大小的线程池

 使用于为了满足资源管理需求而需要限制当前线程数量的场合。使用于负载比较重的服务器

 
  1. import java.util.concurrent.ExecutorService;

  2. import java.util.concurrent.Executors;

  3.  
  4. public class Test {

  5. public static void main(String[] args) {

  6. ExecutorService ex=Executors.newFixedThreadPool(5);

  7.  
  8. for(int i=0;i<5;i++) {

  9. ex.submit(new Runnable() {

  10.  
  11. @Override

  12. public void run() {

  13. for(int j=0;j<10;j++) {

  14. System.out.println(Thread.currentThread().getName()+j);

  15. }

  16.  
  17. }

  18. });

  19. }

  20. ex.shutdown();

  21. }

  22. }

SingleThreadPoolExecutor :单线程池

需要保证顺序执行各个任务的场景 

 
  1. import java.util.concurrent.ExecutorService;

  2. import java.util.concurrent.Executors;

  3.  
  4. public class Test {

  5. public static void main(String[] args) {

  6. ExecutorService ex=Executors.newSingleThreadExecutor();

  7.  
  8. for(int i=0;i<5;i++) {

  9. ex.submit(new Runnable() {

  10.  
  11. @Override

  12. public void run() {

  13. for(int j=0;j<10;j++) {

  14. System.out.println(Thread.currentThread().getName()+j);

  15. }

  16.  
  17. }

  18. });

  19. }

  20. ex.shutdown();

  21. }

  22. }

CashedThreadPool(); 缓存线程池

当提交任务速度高于线程池中任务处理速度时,缓存线程池会不断的创建线程
 适用于提交短期的异步小程序,以及负载较轻的服务器

 
  1. import java.util.concurrent.ExecutorService;

  2. import java.util.concurrent.Executors;

  3.  
  4. public class Test {

  5. public static void main(String[] args) {

  6. ExecutorService ex=Executors.newCachedThreadPool();

  7.  
  8. for(int i=0;i<5;i++) {

  9. ex.submit(new Runnable() {

  10.  
  11. @Override

  12. public void run() {

  13. for(int j=0;j<10;j++) {

  14. System.out.println(Thread.currentThread().getName()+j);

  15. }

  16.  
  17. }

  18. });

  19. }

  20. ex.shutdown();

  21. }

  22. }

线程之间的状态,及他们之间的相互转换

Java创建线程的四种方式