Java的多线程创建方法

1. 直接使用Thread来创建

package com.test.tt;

public class ThreadEx extends Thread{

    private int j;

    public void run(){

        for(j=0; j<100;j++){

            System.out.println("当前的线程名称是："+ getName() + " " +  "当前j的值是：" + j);

        }

    }

    public static void main(String[] args) {

        for(int h=0; h<100;h++){

            if(h==20){
                //这里新建了两个Thread对象

                ThreadEx  threadTest1= new ThreadEx();

                ThreadEx  threadTest2= new ThreadEx();

                threadTest1.start();

                threadTest2.start();

            }

            System.out.println("当前的线程名称是："+ Thread.currentThread().getName() + " " +  "当前h的值是：" + h);

        }

    }

}

2. 通过实现Runnable接口，并将Runnable实现对象作为Thread的Target的方式创建

注：区别于第一种方法，这里可以达到两个线程共享变量i的目的。

package com.test.tt;

public class RunnableEx implements Runnable{

    private int i;

    @Override

    public void run() {

        for(i=0; i<100;i++){

            System.out.println("当前的线程名称是："+ Thread.currentThread().getName() + " " +  "当前i的值是：" + i);

        }

    }

    public static void main(String[] args) {

        for(int j=0;j<100;j++){

            System.out.println("当前的线程名称是："+ Thread.currentThread().getName() + " " +  "当前j的值是：" + j);

            if(j==20){

                RunnableEx REx=new RunnableEx();
                //这里也新建了两个Thread对象，但是里面的Target是同一个Runnable实现类对象

                Thread thread1 = new Thread(REx, "实例1");

                Thread thread2 = new Thread(REx, "实例2");

                thread1.start();

                thread2.start();

            }

        }

    }

}

3. 通过实现Callable接口的方式创建（这是一个具有返回值的创建方式）

注：FutureTask只能启动一个线程

package com.test.tt;

import java.util.concurrent.Callable;

import java.util.concurrent.FutureTask;

public class CallableEx implements Callable{

    @Override

    public Object call() throws Exception {

        int i =0;

        for(;i<1000;i++){

            System.out.println("当前的线程名称是："+ Thread.currentThread().getName() + " " +  "当前i的值是：" + i);

        }

        return i;

    }

    public static void main(String[] args) {

        // TODO Auto-generated method stub

        CallableEx CEx = new CallableEx();

        FutureTask<Integer> task = new FutureTask<Integer>(CEx);

        for(int j=0;j<1000;j++){

            System.out.println("当前的线程名称是："+ Thread.currentThread().getName() + " " +  "当前i的值是：" + j);

            if(j==200){

                Thread thread1 = new Thread(task, "实例1");

                thread1.start();

            }

        }

        try{
            //这里的get()方法可以获取到子线程的返回值,而且在执行时会中断main线程

            System.out.println("线程的返回值：" + task.get());

        }catch(Exception ex){

            ex.printStackTrace();

        }

    }

}

巴特西

Java的多线程创建方法

最新文章

热门文章