Java多线程有两种实现方法,一种是实现Runnable接口,另一种是继承Thread类。
实现Runnable接口的方式:首先创建一个实现了Runnable接口的实例,然后将该实例作为Thread的构造函数的参数传入,最后调用Thread对象的start()方法来启动新创建的线程。
public class MyRunnable implements Runnable { @Override public void run() { System.out.println("MyRunnable is running"); } public static void main(String[] args) { Thread thread = new Thread(new MyRunnable()); thread.start(); // 启动新创建的进程 } }
继承Thread 类的方式:首先创建一个MyThread 类并从Thread 类中派生出来,然后重写run() 方法,最后调用MyThread 对象的start() 方法来启动新创建的进程。
public class MyThread extends Thread { @Override public void run() { System.out.println("MyThread is running"); // 覆盖run() 方法 } public static void main(String[] args) { // main 方法 MyThread myThread = new MyThread(); // 创建MyThread 实例 myThread.start(); // 启动新创建的进程 } }
以下代码显示了如何在程序中运行多线程。
public class Main {
public static void main(String[] args) {
// Create two Thread objects
Thread t1 = new Thread(Main::print);
Thread t2 = new Thread(Main::print);
// Start both threads
t1.start();
t2.start();
}
public static void print() {
for (int i = 1; i <= 500; i++) {
System.out.println(i);
}
}
}
上面的代码生成以下结果。
Java编程语言内置了两种线程同步:
在互斥同步中,在一个时间点只允许一个线程访问代码段。
条件同步通过条件变量和三个操作来实现:等待,信号和广播。
synchronized关键字用于声明需要同步的关键部分。
有两种方法可以使用synchronized关键字:
我们可以通过在方法的返回类型之前使用关键字synchronized来声明一个方法作为临界段。
public class Main {
public synchronized void someMethod_1() {
// Method code goes here
}
public static synchronized void someMethod_2() {
// Method code goes here
}
}
我们可以声明一个实例方法和一个静态方法同步。构造函数不能声明为同步。
以下代码说明了使用关键字synchronized:
public class Main {
public synchronized void someMethod_1() {
// only one thread can execute here at a time
}
public void someMethod_11() {
synchronized (this) {
// only one thread can execute here at a time
}
}
public void someMethod_12() {
// multiple threads can execute here at a time
synchronized (this) {
// only one thread can execute here at a time
}
// multiple threads can execute here at a time
}
public static synchronized void someMethod_2() {
// only one thread can execute here at a time
}
public static void someMethod_21() {
synchronized (Main.class) {
// only one thread can execute here at a time
}
}
public static void someMethod_22() {
// multiple threads can execute here at a time
synchronized (Main.class) {
// only one thread can execute here at a time
}
// multiple threads can execute here at a time
}
}
对wait()方法的调用必须放在synchronized方法或同步块中。
对于当前线程已经获取监视器的对象,必须调用wait()方法。
没有办法唤醒等待集中的特定线程。
public class Main {
private static int myValue = 1;
public static void main(String[] args) {
Thread t = new Thread(() -> {
while (true) {
updateBalance();
}
});
t.start();
t = new Thread(() -> {
while (true) {
monitorBalance();
}
});
t.start();
}
public static synchronized void updateBalance() {
System.out.println("start:" + myValue);
myValue = myValue + 1;
myValue = myValue - 1;
System.out.println("end:" + myValue);
}
public static synchronized void monitorBalance() {
int b = myValue;
if (b != 1) {
System.out.println("Balance changed: " + b);
System.exit(1);
}
}
}
上面的代码生成以下结果。
以下代码显示了上述代码的非同步版本。
public class Main {
private static int myValue = 1;
public static void main(String[] args) {
Thread t = new Thread(() -> {
while (true) {
updateBalance();
}
});
t.start();
t = new Thread(() -> {
while (true) {
monitorBalance();
}
});
t.start();
}
public static void updateBalance() {
System.out.println("start:" + myValue);
myValue = myValue + 1;
myValue = myValue - 1;
System.out.println("end:" + myValue);
}
public static synchronized void monitorBalance() {
int b = myValue;
if (b != 1) {
System.out.println("Balance changed: " + b);
System.exit(1);
}
}
}
上面的代码生成以下结果。
Java regionMatches() 方法JavaString类regionMatches() 方法用于检测两个字符串在一个区域内是否相等。语法public boolean regi...
JavaFX教程 -JavaFX折线图折线图,一种双轴图表,显示了特定时间间隔内数据的动态。对于双轴图表,我们可以定义一系列数据XYChar...
JavaFX 教程 - JavaFX 图像显示JavaFX 可以在场景图形上显示标准图像文件格式。使用javafx.scene.image.Image从本地文件系统或远...
Java教程 -Java静态finalJava静态关键字静态类成员可以独立于该类的任何对象使用。静态成员可以自身使用,而不参考特定实例。这...
Java compareTo() 方法Java Number类compareTo() 方法用于将 Number 对象与方法的参数进行比较。可用于比较 Byte, Long, Integer...