一、继承Thread类
1.1方法
| 方法名 | 说明 |
|---|---|
| void run() | 在线程开启后，此方法将被调用执行 |
| void start() | 使此线程开始执行，Java虚拟机会调用run方法() |
run()方法和start()方法的区别：
- run()：封装线程执行的代码，直接调用，相当于普通方法的调用
- start()：启动线程；然后由JVM调用此线程的run()方法
1.2实现步骤
-
定义一个类MyThread继承Thread类
-
在MyThread类中重写run()方法
-
创建MyThread类的对象
-
启动线程
1.3代码实例
实现一个MyThread类继承Thread，然后重写里面的run()方法。至于说为什么需要重写run()方法是因为run()是用来封装被线程执行的代码
public class MyThread extends Thread{@Overridepublic void run(){for(int i = 0; i <= 100 ; i++){System.out.println(i);}}
}public class ThreadTest {public static void main(String[] args) {MyThread myThread1 = new MyThread();MyThread myThread2 = new MyThread();myThread1.run();myThread2.start();}}二、实现Runnable接口
2.1方法
| 方法名 | 说明 |
|---|---|
| Thread(Runnable target) | 分配一个新的Thread对象 |
| Thread(Runnable target, String name) | 分配一个新的Thread对象 |
2.2实现步骤
-
定义一个类MyRunnable实现Runnable接口
-
在MyRunnable类中重写run()方法
-
创建MyRunnable类的对象
-
创建Thread类的对象，把MyRunnable对象作为构造方法的参数
-
启动线程
2.3代码实例
public class MyRunnable implements Runnable{@Overridepublic void run() {for(int i=0; i<100; i++) {System.out.println(Thread.currentThread().getName()+":"+i);}}
}public class RunnableTest {public static void main(String[] args) {MyRunnable myRunnable = new MyRunnable();//Thread thread = new Thread(myRunnable);Thread thread = new Thread(myRunnable, "fly");Thread thread1 = new Thread(myRunnable, "run");thread.start();;thread1.start();}
}
三、实现Callable接口
3.1方法
| 方法名 | 说明 |
|---|---|
| V call() | 计算结果，如果无法计算结果，则抛出一个异常 |
| FutureTask(Callable<V> callable) | 创建一个 FutureTask，一旦运行就执行给定的 Callable |
| V get() | 如有必要，等待计算完成，然后获取其结果 |
3.2实现步骤
-
定义一个类MyCallable实现Callable接口
-
在MyCallable类中重写call()方法
-
创建MyCallable类的对象
-
创建Future的实现类FutureTask对象，把MyCallable对象作为构造方法的参数
-
创建Thread类的对象，把FutureTask对象作为构造方法的参数
-
启动线程
-
再调用get方法，就可以获取线程结束之后的结果。
3.3代码实例
public class MyCallable implements Callable<String> {@Overridepublic String call() throws Exception {for (int i = 0; i < 100; i++) {System.out.println(i);}//返回值就表示线程运行完毕之后的结果return "完成";}
}public class CallableTest {public static void main(String[] args) throws ExecutionException, InterruptedException {MyCallable myCallable = new MyCallable();// Thread thread = new Thread(myCallable);FutureTask<String> stringFutureTask = new FutureTask<String>(myCallable);Thread thread = new Thread(stringFutureTask);String s = stringFutureTask.get();thread.start();System.out.println(s);}
}三种线程的各自优缺点
-
实现Runnable、Callable接口
-
好处: 扩展性强，实现该接口的同时还可以继承其他的类
-
缺点: 编程相对复杂，不能直接使用Thread类中的方法
-
-
继承Thread类
-
好处: 编程比较简单，可以直接使用Thread类中的方法
-
缺点: 可以扩展性较差，不能再继承其他的类
-
-
Runnable接口和Callable接口区别
-
Callable的call()方法允许用try catch语句块内部处理也可以允许异常向上抛出，而Runnable方法的run()方法异常只能在内部处理。
-
Callable可以有返回结果而Runnable没有。
-
应用：
1.设置和获取线程名称
1.1方法
| 方法名 | 说明 |
|---|---|
| void setName(String name) | 将此线程的名称更改为等于参数name |
| String getName() | 返回此线程的名称 |
| Thread currentThread() | 返回对当前正在执行的线程对象的引用 |
1.2代码示例
public class MyThread extends Thread{public MyThread(){}public MyThread(String name){super(name);}@Overridepublic void run(){for(int i = 0; i <= 100 ; i++){System.out.println(getName() + ":" + i);}}
}public class ThreadTest {public static void main(String[] args) {MyThread myThread1 = new MyThread();MyThread myThread2 = new MyThread();myThread1.setName("thread1");myThread2.setName("thread2");MyThread myThread3 = new MyThread("thread3");MyThread myThread4 = new MyThread("thread4");myThread1.start();myThread2.start();myThread3.start();myThread4.start();System.out.println(Thread.currentThread().getName());}
}
2.线程休眠
2.1方法
| 方法名 | 说明 |
|---|---|
| static void sleep(long millis) | 使当前正在执行的线程停留（暂停执行）指定的毫秒数 |
2.2代码示例
public class MyRunnable implements Runnable{@Overridepublic void run() {for(int i=0; i<100; i++) {try{Thread.sleep(100);}catch (Exception e){e.printStackTrace();}System.out.println(Thread.currentThread().getName()+":"+i);}}
}public class RunnableTest {public static void main(String[] args) {MyRunnable myRunnable = new MyRunnable();Thread thread1 = new Thread(myRunnable);Thread thread2 = new Thread(myRunnable);thread1.start();;thread2.start();}
}
3.线程优先级
3.1方法
| 方法名 | 说明 |
|---|---|
| final int getPriority() | 返回此线程的优先级 |
| final void setPriority(int newPriority) | 更改此线程的优先级线程默认优先级是5；线程优先级的范围是：1-10 |
3.2线程调度
-
分时调度模型：所有线程轮流使用 CPU 的使用权，平均分配每个线程占用 CPU 的时间片
-
抢占式调度模型：优先让优先级高的线程使用 CPU，如果线程的优先级相同，那么会随机选择一个，优先级高的线程获取的 CPU 时间片相对多一些
3.3代码示例
public class MyCallable implements Callable<String> {@Overridepublic String call() throws Exception {for (int i = 0; i < 100; i++) {System.out.println(Thread.currentThread().getName() + "---" + i);}//返回值就表示线程运行完毕之后的结果return "完成";}
}public class CallableTest {public static void main(String[] args) throws ExecutionException, InterruptedException {MyCallable myCallable = new MyCallable();
// Thread thread = new Thread(myCallable);FutureTask<String> stringFutureTask = new FutureTask<String>(myCallable);Thread thread1 = new Thread(stringFutureTask);thread1.setName("thread1");thread1.setPriority(10);thread1.start();MyCallable myCallable2 = new MyCallable();
// Thread thread = new Thread(myCallable);FutureTask<String> stringFutureTask2 = new FutureTask<String>(myCallable);Thread thread2 = new Thread(stringFutureTask2);thread2.setName("thread2");thread2.setPriority(1);thread2.start();}
}4.守护线程
4.1方法
| 方法名 | 说明 |
|---|---|
| void setDaemon(boolean on) | 将此线程标记为守护线程，当运行的线程都是守护线程时，Java虚拟机将退出 |
4.2代码示例
public class MyThread1 extends Thread {@Overridepublic void run() {for (int i = 0; i < 10; i++) {System.out.println(getName() + "---" + i);}}
}
public class MyThread2 extends Thread {@Overridepublic void run() {for (int i = 0; i < 100; i++) {System.out.println(getName() + "---" + i);}}
}
public class Demo {public static void main(String[] args) {MyThread1 t1 = new MyThread1();MyThread2 t2 = new MyThread2();t1.setName("女神");t2.setName("舔狗");//把第二个线程设置为守护线程//当普通线程执行完之后,那么守护线程也没有继续运行下去的必要了.t2.setDaemon(true);t1.start();t2.start();}
}
