「Java同時プログラミング」1.8一時停止スレッド

5912 ワード

【Java同時実行】1.8一時停止スレッド
スレッドを一時停止すると、このスレッドが実行を再開できることを意味します.Javaマルチスレッドではsuspend()メソッドでスレッドを一時停止し,resume()メソッドを使用してスレッドの実行を復元する.
suspendとresumeメソッドの使用方法
public class MyThread extends Thread {

    private long i = 1;

    public static void main(String[] args) {
        try {
            MyThread thread = new MyThread();
            thread.start();
            Thread.sleep(5000);

            //A 
            thread.suspend();
            System.out.println("A="+System.currentTimeMillis()+",i="+thread.getI());
            Thread.sleep(5000);
            System.out.println("A="+System.currentTimeMillis()+",i="+thread.getI());

            //B 
            thread.resume();
            Thread.sleep(5000);

            //C 
            thread.suspend();
            System.out.println("B="+System.currentTimeMillis()+",i="+thread.getI());
            Thread.sleep(5000);
            System.out.println("B="+System.currentTimeMillis()+",i="+thread.getI());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    public long getI() {
        return i;
    }

    public void setI(long i) {
        this.i = i;
    }

    @Override
    public void run() {
        super.run();
        while (true) {
            i++;
        }
    }
}
A=1513740411248,i=2343457221
A=1513740416249,i=2343457221
B=1513740421249,i=5066938112
B=1513740426249,i=5066938112

プログラムの実行結果に基づいて,スレッドを一時停止および復元できることが分かった.
suspendとresumeメソッドの欠点-独占
public class SynchronizedObject {

    public static void main(String[] args) {
        try {
            final SynchronizedObject object = new SynchronizedObject();
            Thread threadA = new Thread() {
                @Override
                public void run() {
                    super.run();
                    object.printString();
                }
            };
            threadA.setName("a");
            threadA.start();
            Thread.sleep(1000);

            Thread threadB = new Thread() {
                @Override
                public void run() {
                    super.run();
                    System.out.println("threadB   ,     printString()  !      begin");
                    System.out.println("  printString()   a        suspend   !");
                    object.printString();
                }
            };
            threadB.setName("b");
            threadB.start();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    synchronized public void printString() {
        System.out.println("begin.");
        if (Thread.currentThread().getName().equals("a")) {
            System.out.println("a     suspend ~");
            Thread.currentThread().suspend();
        }
        System.out.println("end.");
    }
}
begin.
a     suspend ~
threadB   ,     printString()  !      begin
  printString()   a        suspend   !

もう1つの独占ロックの場合も注意してください.
public class MyThread2 extends Thread{

    private long i = 1;

    public long getI() {
        return i;
    }

    public void setI(long i) {
        this.i = i;
    }

    @Override
    public void run() {
        super.run();
        while (true) {
            i++;
            //System.out.println("i="+i);
        }
    }

    public static void main(String[] args) {
        try {
            MyThread2 thread = new MyThread2();
            thread.start();
            Thread.sleep(1000);
            thread.suspend();
            System.out.println("main end");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }
}
main end

プログラムの実行結果はmain endである.でもシステムをout.println("i="+i); コメントを削除します.プログラムの実行結果は次のとおりです.
......
i=183214
i=183215
i=183216
i=183217
i=183218
i=183219
i=183220
i=183221

このときmain endが出力されなかったのはprintlnメソッド内部で実行されたときに同期ロックが解放されなかったためである.println内部のソースコードは次のとおりです.
public void println(String x) {
    synchronized (this) {
            print(x);
            newLine();
        }
    }

これにより、現在のPringStreamオブジェクトのprintlnメソッドは「一時停止」状態となり、ロックは解放されず、mainメソッドのコードSystemとなる.out.println("main end");印刷がなかなかできません.suspend()法は期限切れで廃棄されたが,その期限切れの原因を研究することは非常に有意義である.
suspendとresumeの欠点-非同期
suspendとresumeメソッドを使用する場合も、スレッドの一時停止によるデータの非同期の問題が発生します.
public class MyObject{

    private String name = "name";
    private String pwd = "pwd";

    public void setValue(String name,String pwd){
        this.name=name;
        if(Thread.currentThread().getName().equals("a")){
            System.out.println("  a  !");
            Thread.currentThread().suspend();
        }
        this.pwd=pwd;
    }

    public void printString(){
        System.out.println("name:" + name + ",pwd:" + pwd);
    }

    public static void main(String[] args) throws InterruptedException {
        final MyObject object = new MyObject();
        Thread thread1 = new Thread(){
            @Override
            public void run() {
                super.run();
                object.setValue("root","123456");
            }
        };
        thread1.setName("a");
        thread1.start();
        Thread.sleep(1000);

        Thread thread2 = new Thread(){
            @Override
            public void run() {
                super.run();
                object.printString();
            }
        };
        thread2.start();javascript:void(null)
    }
}
  a  !
name:root,pwd:pwd

プログラムに値が同期しない場合があります.suspendの使用には特に注意が必要です.
解決方法
未完待続...