进程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()语句使两个栈之间发生的