方式一：继承Thread类的方式
1、创建一个继承于Thread类的子类
2、重写Thread类中的run()：将此线程要执行的操作声明在run()
3、创建Thread的子类的对象
4、调用此对象的start():①启动线程 ②调用当前线程的run()方法
方式二：实现Runnable接口的方式
1、创建一个实现Runnable接口的类
2、实现Runnable接口中的抽象方法：run():将创建的线程要执行的操作声 明在此方法中
3、创建Runnable接口实现类的对象
4、将此对象作为参数传递到Thread类的构造器中，创建Thread类的对象
5、调用Thread类中的start():① 启动线程 ② 调用线程的run() --->调用 Runnable接口实现类的run()
方式三：实现Callable接口
说明：
1、与使用Runnable相比， Callable功能更强大些
2、实现的call()方法相比run()方法，可以返回值
3、方法可以抛出异常
4、支持泛型的返回值
5、需要借助FutureTask类，比如获取返回结果
Future接口可以对具体Runnable、Callable任务的执行结果进行取消、查询是否完成、获取结果等。
FutureTask是Futrue接口的唯一的实现类
FutureTask 同时实现了Runnable, Future接口。它既可以作为Runnable被线程执行，又可以作为Future得到Callable的返回值
方式四：使用线程池
说明：
提前创建好多个线程，放入线程池中，使用时直接获取，使用完放回池中。可以避免频繁创建销毁、实现重复利用。类似生活中的公共交通工具。
好处：
1、提高响应速度（减少了创建新线程的时间）
2、降低资源消耗（重复利用线程池中线程，不需要每次都创建）
3、便于线程管理
四种创建多线程的方式写到一个java文件里
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;
import java.util.concurrent.ThreadPoolExecutor;
//方式一
class ThreadTest extends Thread {
@Override
public void run() {
for (int i = 0; i < 10; i++) {
System.out.println(Thread.currentThread().getName() + ":" + i);
}
}
}
// 方式二
class RunnableTest implements Runnable {
@Override
public void run() {
for (int i = 0; i < 10; i++) {
System.out.println(Thread.currentThread().getName() + ":" + i);
}
}
}
// 方式三
class CallableTest implements Callable<Integer> {
@Override
public Integer call() throws Exception {
int sum = 0;
for (int i = 0; i < 10; i++) {
System.out.println(Thread.currentThread().getName() + ":" + i);
sum += i;
}
return sum;
}
}
// 方式四
class ThreadPool implements Runnable {
@Override
public void run() {
for (int i = 0; i < 10; i++) {
System.out.println(Thread.currentThread().getName() + ":" + i);
}
}
}
public class Test {
public static void main(String[] args) {
// 继承Thread
ThreadTest thread = new ThreadTest();
thread.setName("方式一");
thread.start();
// 实现Runnable
RunnableTest runnableTest = new RunnableTest();
Thread thread2 = new Thread(runnableTest, "方式二");
thread2.start();
// 实现Callable<> 有返回值
CallableTest callableTest = new CallableTest();
FutureTask<Integer> futureTask = new FutureTask<>(callableTest);
new Thread(futureTask, "方式三").start();
// 返回值
try {
Integer integer = futureTask.get();
System.out.println("返回值（sum）：" + integer);
} catch (Exception e) {
e.printStackTrace();
}
// 线程池
ExecutorService pool = Executors.newFixedThreadPool(10);
ThreadPoolExecutor executor = (ThreadPoolExecutor) pool;
/*
* 可以做一些操作:
* corePoolSize：核心池的大小
* maximumPoolSize：最大线程数
* keepAliveTime：线程没任务时最多保持多长时间后会终止
*/
executor.setCorePoolSize(5);
// 开启线程
executor.execute(new ThreadPool());
executor.execute(new ThreadPool());
executor.execute(new ThreadPool());
executor.execute(new ThreadPool());
}
}
