Java创建多线程方法
1 继承Thread类,重写run()方法,调用start开启线程
例子:
public class TestThread1 extends Thread{
@Override
public void run() {
// run方法中声明线程主体
System.out.println("这里写线程内逻辑");
}
}
public static void main(String[] args) {
// 创建一个线程对象
TestThread1 testThread = new TestThread1();
// 调用start()方法开启线程
testThread.start();
System.out.println("这里写主线程逻辑");
}
注意:开启的线程默认为用户线程而不是守护线程。当主线程执行结束后,JVM会继续执行用户线程,直到其执行完毕。而如果主线程执行完毕后仍然有守护线程未执行完毕,JVM会立即停止运行。 典型的守护线程是垃圾处理gc。通过setDaemon可以切换线程未守护进程或用户线程。
2 实现runnable接口,重写run方法,执行线程时需要创建一个线程对象,传入runnable接口的实现类
例子:
public class TestThread2 implements Runnable{
@Override
public void run() {
// run方法中声明线程主体
System.out.println("这里写线程内逻辑");
}
}
public static void main(String[] args) {
// 创建一个线程对象
TestThread2 testThread = new TestThread2();
// 注意不同:通过一个新的代理线程,来开启之前定义的线程
new Thread(testThread).start();
System.out.println("这里写主线程逻辑");
}
第一种方法中,Thread类也实现了Runnable接口,因此这里可以使用Thread类来做静态代理。由于Java的单继承特性,推荐使用继承Runnable来创建线程的方法,且方便同一个对象被多个线程使用。用lambda表达式可以更加简单的写做:
new Thread( () -> System.out.println("这里写线程内逻辑")).start();
3 实现Callable接口,重写call方法,创建执行服务,提交执行,获取结果,关闭服务
public class TestThread3 implements Callable<Boolean>{
@Override
public Boolean call() {
// call方法中声明线程主体
System.out.println("这里写线程内逻辑");
return true;
}
}
public static void main(String[] args) {
// 创建线程对象
TestThread3 t1 = new TestThread3();
TestThread3 t2 = new TestThread3();
TestThread3 t3 = new TestThread3();
// 创建执行服务,线程池
ExecutorService service = Executors.newFixedThreadPool(3);
// 提交线程执行
Future<Boolean> result1 = ser.submit(t1);
Future<Boolean> result2 = ser.submit(t2);
Future<Boolean> result3 = ser.submit(t3);
// 获取结果
boolean r1 = result1.get();
boolean r2 = result2.get();
boolean r3 = result3.get();
//关闭服务
service.shutDownNow();
}
该类型可以定义返回值,可以抛出异常
|