Java多线程基础

Thread类的run方法和start方法

 

       Java语言写成的程序一定是先从主线程开始操作，所以必须在程序的某个位置启动新的线程，才能算是真正的多线程程序。start()方法是 Thread类的方法，调用start()方法，就会启动新的线程。请注意，被调用来启动线程的是start()方法，而非run()方法。调用 start()方法之后，Java执行处理系统会在背后启动新的线程。再由这个新的线程调用run()方法。调用start()方法，会有两个操作：

 

• 启动新的线程
• 调用run方法

线程的启动

 

利用Thread类的子类

 

public class PrintThread extends Thread {
      private String msg;
public PrintThread(String msg) {
this.msg = msg;
}
public void run() {
for(int i = 0; i < 10000; i++) {
System.out.print(msg);
}
}

public static void main(String[] args {
new PrintThread("Good!").start();
new PrintThread("Nice!").start();
}
}

 

在main()方法里，先建立PrintThread类的实例后，调用该实例的 start()方法启动线程。建立“PrintThread类的实例”和“启动该实例所对应的线程”是两个完全不同的处理。即使已经建立了实例，仍然必须 等到调用start()方法才会启动线程。主线程在main()方法里启动两个线程，因为main()方法会立即结束，所以主线程也会立即结束，不过整个 程序还没有结束，一直要等到所有线程都已经结束，程序才会结束。不过这里不包括daemon thread。利用Runnable接口

 

Runnable接口是java.lang Package里的接口，声明方法如下：

public interface Runnable {public abstract void run();}已实现Runnable接口的类必须实现run()方法。

public class PrintThread implements Runnable {
private String msg;
public PrintThread(String msg) {
this.msg = msg;
}
public void run() {
for(int i = 0; i < 10000; i++) {
System.out.print(msg);
}
}

public static void main(String[] args {
new Thread(new PrintThread("Good!")).start();
new Thread(new PrintThread("Nice!")).start();
}
}

 

不管是利用Thread类的子类还是利用Runnable接口的实现类来启动线程，都是通过Thread类的start()方法。

 

 

 

线程的暂时停在

 

利用Thread类的sleep()方法即可暂时停在线程的执行操作。注意，sleep()方法是Thread类的静态方法。

 

 

 

线程的共享互斥

 

synchronized方法

 

当 一个方法加上关键字synchronized声明之后，就可以让1个线程操作这个方法。这种线程称为synchronized方法，又称为同步方法。 synchronized实例方法就是使用this锁定去做线程的共享互斥。synchronized类方法是使用该类的类对象的锁定去做线程的共享互斥

 

 

 

线程的协调

 

所 有实例都有一个wait set，wait set是一个在执行该实例的wait方法时、操作停止的线程的集合。一个执行wait()方法时，线程便会暂时停止操作，进入wait set这个休息室。如欲执行wait()方法，线程需获取锁定。但是当线程进入wait set时，已经释放了该实例的锁定。使用notify()方法时，可从wait set里抓取一个线程。线程必须有调用实例的锁定，才能执行notify()方法，这跟调用wait()方法一样。使用notifyAll()方法时，会 将所有在wait set里等待的线程全部拿出来。同样，线程必须获取调用实例的锁定，才能调用notifyAll()方法。注意，wait()、notify()、 notifyAll()方法都是Object类的方法。

 

 

 

Single Threaded Execution Pattern

使用该模式来限制同时只让一个线程运行。先看一个不是使用该模式的多线程的例子，并非线程安全（Thread-safe）的Gate类：

public class Main {
public static void main(String[] args) {
System.out.println("Testing Gate, hit CTRC+C to exit.");
Gate gate = new Gate();
new UserThread(gate, "Alice", "Alaska").start();
new UserThread(gate, "Bobby", "Brazil").start();
new UserThread(gate, "Chris", "Canada").start();
}
}

public class Gate {
private int counter = 0;
private String name = "Nobody";
private String address = "Nowhere";
public void pass(String name, String address) {
this.counter++;
this.name = name;
this.address = address;
check();
}
public String toString() {
return "No. " + counter + " name: " + name + ", address: " + address;
}
private void check() {
if (name.charAt(0) != address.charAt(0)) {
System.out.println("******BROKEN*******" + toString());
}
}

public class UserThread extends Thread {
private final Gate gate;
private final String myname;
private final String myaddress;
public UserThread (Gate gate, String myname, String myaddress) {
this.gate = gate;
this.myname = myname;
this.myaddress =myaddress;
}
public void run() {
System.out.println(this.myname + "Begin");
while(true) {
gate.pass(this.myname,myaddress);
}
}
}
}

执行看看。
由于Gate类不是线程安全的，当多个线程对其的状态进行更改时，会出现与期望不符的结果。可以通过将Gate类改造成线程安全的类来解决这个问题。线程安全最简单的方法即是使用本模式，使同一时间只让一个线程执行。线程安全版的Gate类如下：

public class Gate {
private int counter = 0;
private String name = "Nobody";
private String address = "Nowhere";
public synchronized void pass(String name, String address) {
this.counter++;
this.name = name;
this.address = address;
check();
}
public synchronized String toString() {
return "No. " + counter + " name: " + name + ", address: " + address;
}
private void check() {
if (name.charAt(0) != address.charAt(0)) {
System.out.println("******BROKEN*******" + toString());
}
}
}

即在pass()方法和toString()方法前面加上synchronized关键字，这样Gate类就是线程安全的类了。synchronized锁扮演的角色就是对共享资源的保护。
Single Threaded Execution Pattern的参与者：
SharedResource（共享资源）：在本例中Gate类（准确说是Gate类的实例）是这个SharedResource。 SharedResource是可由多个线程访问的类。在该模式下，我们对unsafeMethod加以防护，限制同时只能有一个线程进行访问，在 Java语言中，将unsafeMethod定义成synchronized方法，就可以实现这个目标。这个必须只让单线程执行的程序范围，我们称为临界 区（critical section）
何时该适用Single Threaded Execution Pattern，当SharedResouce实例可能同时被多个线程访问的时候，并且SharedResource的状态可能变化的时候。
另外注意，使用Single Threaded Execution Pattern 时可能会发生死锁（deadlock）的危险。
性能问题，临界区的大小与执行性能直接相关。首先，获取锁定需要花费时间，其次，线程冲突时必须等待。所以，尽可能缩小临界区的范围，以减少出现线程冲突的机会，可抑制性能的降低。
另外一个问题，synchronized是获取谁的锁定来保护呢？如果实例不同，那么锁定也不同。如果有多个不同的实例，那么多个线程仍然可以分别执行不同实例的synchronized方法。
synchronized方法同时只有一个线程可以执行，当有一个线程正在执行synchronized方法时，其他线程不能进入这个方法。从多线程的角 度看，synchronized方法是原子操作（atomic operation）。在Java语言规格上，long和double的赋值操作并不是原子的。可以在类属性字段前面加上volatile关键字将所有对 该字段的操作变为原子的。

Immutable Pattern

不变模式，该模式的语义与GoF定义的设计模式的不变模式是一样的，即通过定义不变类，来实现线程的安全性。由于类的实例一旦生成，其状态将不会变化，顾其天生就是线程安全的。
使用Immutable Pattern 的Person类

public final class Person {
private final String name;
private final String address;
public Person(String name, String address) {
this.name = name;
this.address = address;
}
public String getName() {
return this.name;
}
public String getAddress() {
return this.address;
}
public String toString() {
return "[ Person: name =" + name + ", address = " + address + " ]";
}
}

public class Main() {
public static void main(String[] args){
Person alice = new Person("Alice", "Alaska");
new PrintPersonThread(alice).start();
new PrintPersonThread(alice).start();
new PrintPersonThread(alice).start();
}
}

public class PrintPersonThread extends Thread {
private Person person;
public PrintPersonThread(Person persion) {
this.person = person;
}
public void run() {
while(true) {
System.out.println(Thread.currentThread().getName() + " prints " + person);
}
}
}