Java 主要是通过 java.lang.Thread
类以及 java.lang.Runnable
接口实现线程机制的。
Thread
类为底层操作系统的线程体系架构提供一套统一接口Runnable
接口为关联 Thread
对象的线程提供执行代码创建 Runnable 有两种方式:
Runnable r = new Runnable() {
@Override
public void run() {
System.out.println("Hello from thread");
}
};
Runnable r = () -> System.out.println("Hello from thread");
通过两种方式创建:
Thread t = new Thread(r);
run()
方法class MyThread extends Thread {
@Override
public void run() {
System.out.println("Hello from thread");
}
}
// ...
MyThread mt = new MyThread();
几个方法:
getName()
: 获取线程名称setName()
: 设置线程名称isAlive()
: 判断线程存活状态,存活返回 true,不存活返回 false(只有执行 start()
方法,线程才启动)getState()
: 获取线程执行状态
线程的执行状态由 Thread.State 枚举常量标识:
setPriority()
: 设置线程优先级
传递给优先级的值介于 Thread.MIN_PRIORITY
和 Thread.MAX_PRIORITY
之间,而 Thread.NORMAL_PRIORITY
则确定了默认的优先级isDaemon()
: 判断线程是否为守护进程。守护进程返回 true,不是返回 falsestart()
: 启动与对象关联的线程。
如果线程之前已经启动且处于运行状态,又或者线程已经死亡,这个方法就会抛出 java.lang.IllegalThreadStateException
当一个线程被中断时,它会抛出 java.lang.InterruptedException
,这一机制由下面的 3 种方法构成:
void interrupt()
: 中断调用此方法的 Thread 对象所关联的线程。该线程的中断状态会被清除static boolean interrupted()
: 验证当前线程是否已经中断。该线程的中断状态会被这个方法清除掉boolean isInterrupted()
: 验证线程是否已经中断。该线程的中断状态不受此方法的影响Thread 类提供了 3 种 join()
方法,允许调用线程等待执行此方法的线程对象所关联的线程执行完毕。
void join()
: 无限期地等待直至该线程死亡void join(long millis)
:该线程死亡之前最多等待 millis 毫秒void join(long millis, int nanos)
:该线程死亡之前最多等待 millis 毫秒加 nanos 纳秒Thread 类声明了一对静态方法致使线程睡眠(暂时性地停止执行)
void sleep(long millis)
:睡眠 millis 毫秒数void sleep(long millis, int nanos)
:睡眠 millis 毫秒数和 nanos 纳秒数首先讲一下多线程的实现思路,主要有两种方法:
run()
方法class MyThread extends Thread{
private int ticket = 5;
@Override
public void run(){
for (int i=0;i<10;i++)
{
if(ticket > 0){
System.out.println("ticket = " + ticket--);
}
}
}
}
class ThreadDemo{
public static void main(String[] args){
new MyThread().start();
new MyThread().start();
new MyThread().start();
}
}
Runnable
接口,实现多线程class MyThread implements Runnable{
private int ticket = 5;
@Override
public void run(){
for (int i=0;i<10;i++)
{
if(ticket > 0){
System.out.println("ticket = " + ticket--);
}
}
}
}
class RunnableDemo{
public static void main(String[] args){
MyThread my = new MyThread();
new Thread(my).start();
new Thread(my).start();
new Thread(my).start();
}
}
这两种方法一样的,只有执行了 start()
命令,才会开始执行线程。
其中继承 Thread 生成的线程每一个都是独立的,实现 Runnable 生成的线程是共享资源的,也就是我们上边的例子,最后输出的结果不一样:
ticket = 5
ticket = 4
ticket = 3
ticket = 2
ticket = 1
ticket = 5
ticket = 4
ticket = 3
ticket = 2
ticket = 1
ticket = 5
ticket = 4
ticket = 3
ticket = 2
ticket = 5
ticket = 4
ticket = 3
ticket = 2
ticket = 1
start()
操作,线程才会被创建执行