线程

进程A和进程B的内存独立不共享。
线程A和线程B在Java语言中,线程A和线程B,堆内存和方法区内存共享,但栈内存独立,一个线程一个栈
假设启动10个线程,会有10个栈空间,每个栈和每个栈之间,互不干扰,各自执行各自的,这就是多线程并发,Java之所以有多线程机制,目的就是为了提高程序的处理效率

Java语言中,实现线程有两种方式

第一种:编写一个类,直接继承java.lang.Thread,重写run方法。
public class ThreadTest02
{
    public static void main(String[] args)
    {
        //这里是main方法,这里的代码属于主线程,在主栈中运行。
        //新建一个分支线程对象
        MyThread myThread=new MyThread();
        //启动线程
        //start()方法的作用是:启动一个分支线程,在JVM中开辟一个新的栈空间,这段代码在任务完成之后瞬间就结束了
        //这段代码的任务只是为了开启一个新的栈空间,只要新的栈空间开出来,start()方法就结束了,线程就启动成功了
        //启动成功的线程会自动调用run方法,并且run方法在分支栈的栈底部(压栈)
        //run方法在分支栈的栈底部,main方法在主栈的栈底部,run和main是平级的
        myThread.start();
        //这里的代码还是运行在主线程中
        for (int i = 0; i < 1000; i++) {
            System.out.println("主线程---->"+i);
        }
    }

}

class MyThread extends Thread {
    @Override
    public void run()
    {
        //编写程序,这段程序运行在分支线程中(分支线)
        for(int i=0;i<1000;i++){
            System.out.println("分支线程---->"+i);
        }
    }
}
第二种:编写一个类,实现java.lang.Runnable接口,实现run方法。
public class ThreadTest03
{
    public static void main(String[] args)
    {
        //创建一个可运行的对象
        MyRunnable myRunnable=new MyRunnable();
        //将可运行的对象封装成一个线程对象
        Thread thread=new Thread(myRunnable);
        //启动线程
        thread.start();

        for (int i = 0; i < 100; i++) {
            System.out.println("主线程--->"+i);
        }
    }
}

class MyRunnable implements Runnable{

    @Override
    public void run()
    {
        for (int i = 0; i < 100; i++) {
            System.out.println("支线程--->"+i);
        }
    }
}
匿名内部类方式
public class ThreadTest04
{
    public static void main(String[] args)
    {
        //创建线程对象,采用匿名内部类方式
        //这是通过一个没有名字的类,new出来的对象
        Thread thread=new Thread(new Runnable(){
            @Override
            public void run()
            {
                for (int i = 0; i < 100; i++) {
                    System.out.println("thread线程--->"+i);
                }
            }
        });

        thread.start();

        for (int i = 0; i < 100; i++) {
            System.out.println("main线程--->"+i);
        }
    }
} 

线程的生命周期

线程名字

1、获取线程对象名字:
String name = 线程对象.getName();
2、设置线程对象名:
线程对象.setName("线程名字");
3、若没有给线程对象设置名字时,默认的名字有什么规律?
Thread-0
Thread-1
Thread-2
······
4、获取当前线程对象
Thread t= Thread.currentThread();
返回值t就是当前线程

关于线程的sleep方法:

static void sleep(long millis)
1、静态方法:Thread.sleep(1000);
2、参数时毫秒
3、作用:让让当前线程进入休眠,进入”阻塞状态“,放弃占有CPU时间片,让给其他线程使用。
这行代码出现在A线程中,A线程就会进入休眠。
这行代码出现在B线程中,B线程就会进入休眠。
4、Thread.sleep()方法,可以做到这种效果
间隔特定的事件,去执行一段特定的代码,每隔多久执行一次。

关于sleep的面试题

public class ThreadTest06
{
    public static void main(String[] args)
    {
        Thread t=new MyThread3();
        t.setName("t");
        t.start();

        try {
            t.sleep(1000*5);//在执行的时候还是会转换成:Thread.sleep(1000*5);
                                  //这行代码的作用市:让当前线程进入休眠,也就是说main线程进入休眠
                                  //这样代码出现在main方法中,main线程睡眠
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println("hello,world");
    }
}

class MyThread3 extends Thread{
    public void run(){
        for (int i = 0; i < 10; i++) {
            System.out.println("支线程--->"+i);
        }
    }
}

重点:run()当中的异常不能throw,只能try,catch
因为run()方法在父类中没有抛出任何异常,子类不能比父类抛出更多的异常

将正在睡眠的线程唤醒(终止)

public class ThreadTest07
{
    public static void main(String[] args)
    {
        Thread t=new Thread(new MyRunnable2());
        t.setName("t");
        t.start();
        //终断t线程的睡眠(这种终断睡眠的方式依靠了java的异常处理机制)
        t.interrupt();
    }
}

class MyRunnable2 implements Runnable{

    @Override
    public void run()
    {
        System.out.println(Thread.currentThread().getName()+"--->begin");
        try {
            Thread.sleep(1000*60*60*24*365);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName()+"--->end");
    }
}

依靠的是Java异常处理机制,当执行t.interrupt()方法,会使run中的Thread.sleep(1000606024365);语句报错,打印错误,整个try/catcha结构结束。

合理的终止一个线程的方法

public class ThreadTest08
{
    public static void main(String[] args)
    {
        MyRunnable3 r3=new MyRunnable3();
        Thread t=new Thread(r3);
        t.setName("t");
        t.start();
        for (int i = 0; i < 5; i++) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        r3.flag=false;
    }
}

class MyRunnable3 implements Runnable{

    boolean flag=true;
    @Override
    public void run()
    {
        for (int i = 0; i < 100; i++) {
            if (flag){
                System.out.println(Thread.currentThread().getName()+"--->"+i);
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }else {
                return;
            }

        }
    }
}

合并线程

class MyThread1 extends Thread {
  public void doSome(){
    MyThread2 t=new MyThread2();
    t.join();//当前线程进入阻塞,t线程执行,直到t线程结束,当前线程才可以执行
  }
}
class MyThread2 extends Thread{
}
package thread;

public class ThreadTest09
{
    public static void main(String[] args)
    {
        System.out.println("main 启动");
        Thread thread=new Thread(new MyRunnable4());
        thread.setName("t");
        thread.start();
        try {
            thread.join();//将thread合并到当前线程中,使当前线程阻塞,thread线程执行直到结束
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("main 关闭");
    }
}

class MyRunnable4 implements Runnable{

    @Override
    public void run()
    {
        for (int i = 0; i < 1000; i++) {
            String name=Thread.currentThread().getName();
            System.out.println(name+"--->"+i);
        }    
    }
}

join()语句使两个栈之间发生的

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。