线程创建的3种方式

蔚落 2022-06-05 09:25 274阅读 0赞

1，继承Thread类来进行创建

package com.thread;
    
    public class SubThread extends Thread {
    
    	static int a = 0;
    
    	@Override
    	public void run() {
    		for (int i = 0; i < 100; i++) {
    			a++;
    			System.out.println("thread's name is :" + Thread.currentThread().getName()
    					+ ";and this is " + a + " times");
    		}
    	}
    	public static void main(String[] args) {
     //直接创建其Thread的子类的对象，则就是一个线程。
    		new SubThread().start();
    		new SubThread().start();
    	}
    }

2，实现Runnable接口

package com.thread;
    
    public class SubThread implements Runnable {
    
    	static int a = 0;
    
    	@Override
    	public void run() {
    		for (int i = 0; i < 100; i++) {
    			a++;
    			System.out.println("thread's name is :" + Thread.currentThread().getName()
    					+ ";and this is " + a + " times");
    		}
    	}
    
    	public static void main(String[] args) {
    		// 先创建一个实现Runnable接口的子类的对象，然后再让它做Thread构造方法的target，同时也可以再添加一个参数给线程取名字的。
    		SubThread runnableThread = new SubThread();
    		new Thread(runnableThread, "123").start();
    
    	}
    }

3，通过callable和futureTask来实现

package com.thread;
    
    import java.util.concurrent.Callable;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.FutureTask;
    
    public class SubThread implements Callable<Integer> {
    
    	static int a = 0;
    
    	// 这里的call方法类似之前的run方法
    	@Override
    	public Integer call() throws Exception {
    		for (int i = 0; i < 100; i++) {
    			a++;
    			System.out.println("thread's name is :" + Thread.currentThread().getName()
    					+ ";and this is " + a + " times");
    		}
    		return a;
    	}
    
    	public static void main(String[] args) {
    
    		System.out.println("thread's name is :" + Thread.currentThread().getName());
    		// 创建callable子类的对象，然后再通过FutureTask来对其进行封装一下，再拿给Thread作target
    		SubThread callableThread = new SubThread();
    		FutureTask<Integer> futureTask = new FutureTask<Integer>(callableThread);
    		new Thread(futureTask).start();
    		try {
    			System.out.println("the method returns " + futureTask.get());
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		} catch (ExecutionException e) {
    			e.printStackTrace();
    		}
    
    	}
    }