Java多线程模式
Java多线程模式
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类的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);
}
}
}
Immutable Pattern的参与者为不变者。Immutable Pattern何时适用，当实例产生后，状态不再变化；实例需要共享，而且访问频繁时。Java语言的标准类库中有许多使用Immutable的类，例如：java.lang.String、java.lang.Integer\java.lang.Short这些基本类型的包装类。
|
评论暂时关闭