Java：线程创建方式

电玩女神 2024-03-22 14:53 100阅读 0赞

#### 扩展Thread类 ####

public class MyThread extends Thread {
        
    
        @Override
        public void run() {
        
            System.out.println(getName() + " 线程运行起来了");
        }
    }

public class Main {
        
        public static void main(String[] args) {
        
            new MyThread().start();
            System.out.println(Thread.currentThread().getName());
        }
    }

#### 实现Runnable接口 ####

public class MyRunnable implements Runnable {
        
        @Override
        public void run() {
        
            System.out.println("实现接口的线程启动起来了");
        }
    }

public class Main {
        
        public static void main(String[] args) {
        
        
            new Thread(new MyRunnable()).start();
            System.out.println(Thread.currentThread().getName());
        }
    }

#### 实现Callable 接口 ####

Callable 接口是一个与Runnable 接口非常相似的接口。Callable 接口的主要特征如下。

*  接口。有简单类型参数，与call()方法的返回类型相对应。
 *  声明了call()方法。执行器运行任务时，该方法会被执行器执行。它必须返回声明中指定类型的对象。
 *  call()方法可以抛出任何一种校验异常。可以实现自己的执行器并重载afterExecute()方法来处理这些异常。

import java.util.concurrent.ExecutionException;
    import java.util.concurrent.FutureTask;
    
    public class Main {
        
        
        public static void main(String[] args) throws ExecutionException, InterruptedException {
        
            
            MyCallable myCallable = new MyCallable();
            // 设置Callable对象，泛型表示Callable的返回类型
            FutureTask<String> futureTask = new FutureTask<String>(myCallable);
            // 启动处理线程
            new Thread(futureTask).start();
            // 同步等待线程运行的结果
            String result = futureTask.get();
            // 5s后得到结果
            System.out.println(result);
        }
    }

import java.util.concurrent.Callable;
    
    public class MyCallable implements Callable<String> {
        
        
        @Override
        public String call() throws Exception {
        
            Thread.sleep(5000);
            return "hello world call() invoked!";
        }
    }

import java.util.concurrent.*;
    
    public class Main2 {
        
    
        public static void main(String[] args) throws ExecutionException, InterruptedException {
        
    
            ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 5, 1, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10)) {
        
                @Override
                protected void afterExecute(Runnable r, Throwable t) {
        
                    super.afterExecute(r, t);
                }
            };
            
            Future<String> future = executor.submit(new MyCallable());
            String s = future.get();
            System.out.println(s);
            executor.shutdown();
        }
    }