欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

java多线程Thread的实现方法代码详解

程序员文章站 2024-02-25 20:00:15
之前有简单介绍过java多线程的使用,已经thread类和runnable类,为了更好地理解多线程,本文就thread进行详细的分析。 start() 我们先来看看...

之前有简单介绍过java多线程的使用,已经thread类和runnable类,为了更好地理解多线程,本文就thread进行详细的分析。

start()

我们先来看看api中对于该方法的介绍:

使该线程开始执行;java 虚拟机调用该线程的 run 方法。

结果是两个线程并发地运行;当前线程(从调用返回给 start 方法)和另一个线程(执行其 run 方法)。

多次启动一个线程是非法的。特别是当线程已经结束执行后,不能再重新启动。

用start方法来启动线程,真正实现了多线程运行,这时无需等待run方法体代码执行完毕而直接继续执行下面的代码。通过调用thread类的 start()方法来启动一个线程,这时此线程处于就绪(可运行)状态,并没有运行,一旦得到cpu时间片,就开始执行run()方法,这里方法 run()称为线程体,它包含了要执行的这个线程的内容,run方法运行结束,此线程随即终止。

start方法是开启线程的方法,使用后java会创建一个新的线程执行run里的方法。这是一个小demo:

    for(int i=0;i<3;i++){
      thread t= new thread(new runnable() {
        @override
        public void run() {
      system.out.println(thread.currentthread().getname()+" start");
          try {
            thread.sleep(1000);
          } catch (interruptedexception e) {
            e.printstacktrace();
          }
      system.out.println(thread.currentthread().getname()+" end");
        }
      });
      t.start();
    }
    system.out.println("it is over");

执行结果:
it is over
thread-1 start
thread-0 start
thread-2 start
thread-0 end
thread-1 end
thread-2 end

由于多线程是有随机性的,所以每次的结果可能都不一样,这一点也是我们需要注意的,线程的执行顺序和调用顺序并不一致。

run()

run方法就是调用thread设置的runnable的run方法,将上面的demo进行修改:

    for(int i=0;i<3;i++){
      thread t= new thread(new runnable() {
        
        @override
        public void run() {
      system.out.println(thread.currentthread().getname()+" start");
          try {
            thread.sleep(1000);
          } catch (interruptedexception e) {
            e.printstacktrace();
          }
      system.out.println(thread.currentthread().getname()+" end");
        }
      });
      t.run();
    }
    system.out.println("it is over");

执行结果:
main start
main end
main start
main end
main start
main end
it is over
run方法的直接结果和start有很大的差别,完全是按顺序执行,并没有开启新线程。

stop()

stop方法是强制停止线程的执行,是非安全的,不要使用此方法。在调用stop时, 会对锁定的资源进行释放,但这种释放是非一致的,容易引起程序问题。如果想要控制线程的停止,可以使用自定义变量来判断或者isinterrupted()方法:

class thread1 extends thread {
  @override
  public void run() {
    //判断线程体是否运行
    while (!isinterrupted()) {
      // do something
    }
  }  
}

interrupt()

interrupt的作用是通知线程,你已经被中断的,但具体的中断执行需要在线程自定义处理,甚至你可以不理会继续执行。具体的中孤单是会线程执行join、wait、sleep方法时,抛出interruptedexception。

thread t1 = new thread(new runnable() {
        @override
        public void run() {
            system.out.println(thread.currentthread().getname()+" start");
            try {
              for(int i=0;i<100000;i++){
                system.out.println(i+"");
                thread.sleep(1);
              }
            } catch (interruptedexception e) {
              system.out.println("the thread is interrupted");//可以在这里做资源释放,日志记录等
              e.printstacktrace();
            }
            system.out.println(thread.currentthread().getname()+" end");
          }
      });
      t1.start();
      thread.sleep(100);
      t1.interrupt();

执行结果:

65
66
67
68
the thread is interrupted
java.lang.interruptedexception: sleep interrupted
thread-0 end
  at java.lang.thread.sleep(native method)
  at com.wk.aqi.act.test$1.run(test.java:23)
  at java.lang.thread.run(thread.java:745)

isinterrupted()

判断线程是否中断,在执行上面的interrupt方法后,会return true。

setpriority(int newpriority)和getpriority()
设置线程的优先级和获取线程的优先级,cpu分配的资源给侧重给priority高的线程。

thread t1 = new thread(new runnable() {
        @override
        public void run() {
            long t = system.currenttimemillis();
            system.out.println(thread.currentthread().getname()+" start");
            for(int i=0;i<1000;i++){
              try {
                thread.sleep(1);
              } catch (interruptedexception e) {
                // todo auto-generated catch block
                e.printstacktrace();
              }
            }
            system.out.println(thread.currentthread().getname()+" t1 end "+(system.currenttimemillis()-t));
          }
      });
      thread t2 = new thread(new runnable() {
        @override
        public void run() {
          long t = system.currenttimemillis();
          system.out.println(thread.currentthread().getname()+" start");
          for(int i=0;i<1000;i++){
            try {
              thread.sleep(1);
            } catch (interruptedexception e) {
              // todo auto-generated catch block
              e.printstacktrace();
            }
          }
          system.out.println(thread.currentthread().getname()+" t2 end "+(system.currenttimemillis()-t));
        }
      });
      t1.setpriority(10);
      t2.setpriority(1);
      t2.start();
      t1.start();

执行结果:

thread-0 start
thread-1 start
thread-0 t1 end 1357
thread-1 t2 end 1371

在优先级一样的情况下,t1和t2是几乎同时完成的,在优先级不一样的情况,有明显的差别。

getname()

比较简单,获取线程的名称。

join()和join(long millis)

jion方法的作用是等待线程执行完成,join(long millis)可以设置最长等待时间。比如主线程需要等待子线程完成,获取子线程的结果后才能继续往下执行,这时候就可以使用join方法

thread t1 = new thread(new runnable() {
      @override
      public void run() {
          long t = system.currenttimemillis();
          system.out.println(thread.currentthread().getname()+" start");
          try {
            thread.sleep(1000);
          } catch (interruptedexception e) {
            // todo auto-generated catch block
            e.printstacktrace();
          }
          system.out.println(thread.currentthread().getname()+" t1 end "+(system.currenttimemillis()-t));
        }
    });
    t1.start();
    t1.join();
    system.out.println("等待t1执行完,再执行");

执行结果:

thread-0 start
thread-0 t1 end 1001
等待t1执行完,再执行

总结

以上就是本文关于java多线程thread的实现方法代码详解的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题,如有不足之处,欢迎留言指出。