关于后端:Java-多线程编程

5次阅读

共计 5983 个字符，预计需要花费 15 分钟才能阅读完成。

Java 多线程编程

Java 给多线程编程提供了内置的反对。一条线程指的是过程中一个繁多程序的控制流，一个过程中能够并发多个线程，每条线程并行执行不同的工作。多线程是多任务的一种特地的模式，但多线程应用了更小的资源开销。这里定义和线程相干的另一个术语 – 过程：一个过程包含由操作系统调配的内存空间，蕴含一个或多个线程。一个线程不能独立的存在，它必须是过程的一部分。一个过程始终运行，直到所有的非守护线程都完结运行后能力完结。多线程能满足程序员编写高效率的程序来达到充分利用 CPU 的目标。一个线程的生命周期线程是一个动静执行的过程，它也有一个从产生到死亡的过程。下图显示了一个线程残缺的生命周期。

新建状态: 应用 new 关键字和 Thread 类或其子类建设一个线程对象后，该线程对象就处于新建状态。它放弃这个状态直到程序 start() 这个线程。就绪状态: 当线程对象调用了 start()办法之后，该线程就进入就绪状态。就绪状态的线程处于就绪队列中，要期待 JVM 里线程调度器的调度。运行状态: 如果就绪状态的线程获取 CPU 资源，就能够执行 run()，此时线程便处于运行状态。处于运行状态的线程最为简单，它能够变为阻塞状态、就绪状态和死亡状态。阻塞状态: 如果一个线程执行了 sleep（睡眠）、suspend（挂起）等办法，失去所占用资源之后，该线程就从运行状态进入阻塞状态。在睡眠工夫已到或取得设施资源后能够从新进入就绪状态。能够分为三种：期待阻塞：运行状态中的线程执行 wait() 办法，使线程进入到期待阻塞状态。同步阻塞：线程在获取 synchronized 同步锁失败 (因为同步锁被其余线程占用)。其余阻塞：通过调用线程的 sleep() 或 join() 收回了 I/O 申请时，线程就会进入到阻塞状态。当 sleep() 状态超时，join() 期待线程终止或超时，或者 I/O 处理完毕，线程从新转入就绪状态。死亡状态: 一个运行状态的线程实现工作或者其余终止条件产生时，该线程就切换到终止状态。线程的优先级每一个 Java 线程都有一个优先级，这样有助于操作系统确定线程的调度程序。Java 线程的优先级是一个整数，其取值范畴是 1（Thread.MIN_PRIORITY）– 10（Thread.MAX_PRIORITY）。默认状况下，每一个线程都会调配一个优先级 NORM_PRIORITY（5）。具备较高优先级的线程对程序更重要，并且应该在低优先级的线程之前调配处理器资源。然而，线程优先级不能保障线程执行的程序，而且十分依赖于平台。创立一个线程 Java 提供了三种创立线程的办法：通过实现 Runnable 接口；通过继承 Thread 类自身；通过 Callable 和 Future 创立线程。通过实现 Runnable 接口来创立线程创立一个线程，最简略的办法是创立一个实现 Runnable 接口的类。为了实现 Runnable，一个类只须要执行一个办法调用 run()，申明如下：public void run() 你能够重写该办法，重要的是了解的 run() 能够调用其余办法，应用其余类，并申明变量，就像主线程一样。在创立一个实现 Runnable 接口的类之后，你能够在类中实例化一个线程对象。Thread 定义了几个构造方法，上面的这个是咱们常常应用的：Thread(Runnable threadOb,String threadName); 这里，threadOb 是一个实现 Runnable 接口的类的实例，并且 threadName 指定新线程的名字。新线程创立之后，你调用它的 start() 办法它才会运行。void start(); 上面是一个创立线程并开始让它执行的实例：实例

class RunnableDemo implements Runnable {
   private Thread t;
   private String threadName;
   
   RunnableDemo(String name) {
      threadName = name;
      System.out.println("Creating" +  threadName);
   }
   
   public void run() {System.out.println("Running" +  threadName);
      try {for(int i = 4; i > 0; i--) {System.out.println("Thread:" + threadName + "," + i);
            // 让线程睡眠一会
            Thread.sleep(50);
         }
      }catch (InterruptedException e) {System.out.println("Thread" +  threadName + "interrupted.");
      }
      System.out.println("Thread" +  threadName + "exiting.");
   }
   
   public void start () {System.out.println("Starting" +  threadName);
      if (t == null) {t = new Thread (this, threadName);
         t.start ();}
   }
}
 
public class TestThread {public static void main(String args[]) {RunnableDemo R1 = new RunnableDemo( "Thread-1");
      R1.start();
      
      RunnableDemo R2 = new RunnableDemo("Thread-2");
      R2.start();}   
}

编译以上程序运行后果如下：Creating Thread-1
Starting Thread-1
Creating Thread-2
Starting Thread-2
Running Thread-1
Thread: Thread-1, 4
Running Thread-2
Thread: Thread-2, 4
Thread: Thread-1, 3
Thread: Thread-2, 3
Thread: Thread-1, 2
Thread: Thread-2, 2
Thread: Thread-1, 1
Thread: Thread-2, 1
Thread Thread-1 exiting.
Thread Thread-2 exiting. 通过继承 Thread 来创立线程创立一个线程的第二种办法是创立一个新的类，该类继承 Thread 类，而后创立一个该类的实例。继承类必须重写 run() 办法，该办法是新线程的入口点。它也必须调用 start() 办法能力执行。该办法只管被列为一种多线程实现形式，然而实质上也是实现了 Runnable 接口的一个实例。
实例

class ThreadDemo extends Thread {
   private Thread t;
   private String threadName;
   
   ThreadDemo(String name) {
      threadName = name;
      System.out.println("Creating" +  threadName);
   }
   
   public void run() {System.out.println("Running" +  threadName);
      try {for(int i = 4; i > 0; i--) {System.out.println("Thread:" + threadName + "," + i);
            // 让线程睡眠一会
            Thread.sleep(50);
         }
      }catch (InterruptedException e) {System.out.println("Thread" +  threadName + "interrupted.");
      }
      System.out.println("Thread" +  threadName + "exiting.");
   }
   
   public void start () {System.out.println("Starting" +  threadName);
      if (t == null) {t = new Thread (this, threadName);
         t.start ();}
   }
}
 
public class TestThread {public static void main(String args[]) {ThreadDemo T1 = new ThreadDemo( "Thread-1");
      T1.start();
      
      ThreadDemo T2 = new ThreadDemo("Thread-2");
      T2.start();}   
}

编译以上程序运行后果如下：Creating Thread-1
Starting Thread-1
Creating Thread-2
Starting Thread-2
Running Thread-1
Thread: Thread-1, 4
Running Thread-2
Thread: Thread-2, 4
Thread: Thread-1, 3
Thread: Thread-2, 3
Thread: Thread-1, 2
Thread: Thread-2, 2
Thread: Thread-1, 1
Thread: Thread-2, 1
Thread Thread-1 exiting.

Thread Thread-2 exiting.Thread 办法下表列出了 Thread 类的一些重要办法：序号办法形容 1public void start()使该线程开始执行；Java 虚拟机调用该线程的 run 办法。2public void run()如果该线程是应用独立的 Runnable 运行对象结构的，则调用该 Runnable 对象的 run 办法；否则，该办法不执行任何操作并返回。3public final void setName(String name)扭转线程名称，使之与参数 name 雷同。4public final void setPriority(int priority) 更改线程的优先级。5public final void setDaemon(boolean on)将该线程标记为守护线程或用户线程。6public final void join(long millisec)期待该线程终止的工夫最长为 millis 毫秒。7public void interrupt()中断线程。8public final boolean isAlive()测试线程是否处于活动状态。上述办法是被 Thread 对象调用的，上面表格的办法是 Thread 类的静态方法。序号办法形容 1public static void yield()暂停以后正在执行的线程对象，并执行其余线程。2public static void sleep(long millisec)在指定的毫秒数内让以后正在执行的线程休眠（暂停执行），此操作受到零碎计时器和调度程序精度和准确性的影响。3public static boolean holdsLock(Object x)当且仅当以后线程在指定的对象上放弃监视器锁时，才返回 true。4public static Thread currentThread()返回对以后正在执行的线程对象的援用。5public static void dumpStack()将以后线程的堆栈跟踪打印至规范谬误流。实例如下的 ThreadClassDemo 程序演示了 Thread 类的一些办法：DisplayMessage.java 文件代码：// 文件名 : DisplayMessage.java
// 通过实现 Runnable 接口创立线程
public class DisplayMessage implements Runnable {
   private String message;
   
   public DisplayMessage(String message) {this.message = message;}
   
   public void run() {while(true) {System.out.println(message);
      }
   }
}GuessANumber.java 文件代码：// 文件名 : GuessANumber.java
// 通过继承 Thread 类创立线程
 
public class GuessANumber extends Thread {
   private int number;
   public GuessANumber(int number) {this.number = number;}
   
   public void run() {
      int counter = 0;
      int guess = 0;
      do {guess = (int) (Math.random() * 100 + 1);
         System.out.println(this.getName() + "guesses" + guess);
         counter++;
      } while(guess != number);
      System.out.println("** Correct!" + this.getName() + "in" + counter + "guesses.**");
   }
}ThreadClassDemo.java 文件代码：// 文件名 : ThreadClassDemo.java
public class ThreadClassDemo {public static void main(String [] args) {Runnable hello = new DisplayMessage("Hello");
      Thread thread1 = new Thread(hello);
      thread1.setDaemon(true);
      thread1.setName("hello");
      System.out.println("Starting hello thread...");
      thread1.start();
      
      Runnable bye = new DisplayMessage("Goodbye");
      Thread thread2 = new Thread(bye);
      thread2.setPriority(Thread.MIN_PRIORITY);
      thread2.setDaemon(true);
      System.out.println("Starting goodbye thread...");
      thread2.start();
 
      System.out.println("Starting thread3...");
      Thread thread3 = new GuessANumber(27);
      thread3.start();
      try {thread3.join();
      }catch(InterruptedException e) {System.out.println("Thread interrupted.");
      }
      System.out.println("Starting thread4...");
      Thread thread4 = new GuessANumber(75);
      
      thread4.start();
      System.out.println("main() is ending...");
   }
}
正文完
后端
发表至： 后端
2023-02-13
 0
关于后端:使用Optional优雅避免空指针异常
关于后端:Flink-数据集成服务在小红书的降本增效实践
关于后端:Linux-TCPIP-协议栈调优
关于后端:FoxnicSQL-11-DAO-特性-事务管理

站内搜索

-「」