一个信号类

chenyajun5

在编写多线程程序经常要用到的多线程信号类。。
[color="#000080"]public[color="#000000"] [color="#000080"]class[color="#000000"] Semaphore {
    [color="#008000"]/** current number of available permits **/[color="#000000"]
    [color="#000080"]protected[color="#000000"] [color="#000080"]long[color="#000000"] [color="#800080"]permits[color="#000000"];
    [color="#000080"]public[color="#000000"] Semaphore([color="#000080"]long[color="#000000"] initialPermits) {
        [color="#800080"]permits[color="#000000"] = initialPermits;
    }
    [color="#000080"]public[color="#000000"] [color="#000080"]void[color="#000000"] acquire() [color="#000080"]throws[color="#000000"] InterruptedException {
        [color="#000080"]if[color="#000000"] (Thread.interrupted()) {
            [color="#000080"]throw[color="#000000"] [color="#000080"]new[color="#000000"] InterruptedException();
        }
        [color="#000080"]synchronized[color="#000000"] ([color="#000080"]this[color="#000000"]) {
            [color="#000080"]try[color="#000000"] {
                [color="#000080"]while[color="#000000"] ([color="#800080"]permits[color="#000000"] [color="#000000"]) {
                    wait();
                }
                --[color="#800080"]permits[color="#000000"];
            }
            [color="#000080"]catch[color="#000000"] (InterruptedException ex) {
                notify();
                [color="#000080"]throw[color="#000000"] ex;
            }
        }
    }
    [color="#000080"]public[color="#000000"] [color="#000080"]boolean[color="#000000"] attempt([color="#000080"]long[color="#000000"] msecs) [color="#000080"]throws[color="#000000"] InterruptedException {
        [color="#000080"]if[color="#000000"] (Thread.interrupted()) {
            [color="#000080"]throw[color="#000000"] [color="#000080"]new[color="#000000"] InterruptedException();
        }
        [color="#000080"]synchronized[color="#000000"] ([color="#000080"]this[color="#000000"]) {
            [color="#000080"]if[color="#000000"] ([color="#800080"]permits[color="#000000"] > [color="#0000ff"]0[color="#000000"]) {
                --[color="#800080"]permits[color="#000000"];
                [color="#000080"]return[color="#000000"] [color="#000080"]true[color="#000000"];
            }
            [color="#000080"]else[color="#000000"] [color="#000080"]if[color="#000000"] (msecs [color="#000000"]) {
                [color="#000080"]return[color="#000000"] [color="#000080"]false[color="#000000"];
            }
            [color="#000080"]else[color="#000000"] {
                [color="#000080"]try[color="#000000"] {
                    [color="#000080"]long[color="#000000"] startTime = System.currentTimeMillis();
                    [color="#000080"]long[color="#000000"] waitTime = msecs;
                    [color="#000080"]for[color="#000000"] (; ;) {
                        wait(waitTime);
                        [color="#000080"]if[color="#000000"] ([color="#800080"]permits[color="#000000"] > [color="#0000ff"]0[color="#000000"]) {
                            --[color="#800080"]permits[color="#000000"];
                            [color="#000080"]return[color="#000000"] [color="#000080"]true[color="#000000"];
                        }
                        [color="#000080"]else[color="#000000"] {
                            waitTime = msecs - (System.currentTimeMillis() - startTime);
                            [color="#000080"]if[color="#000000"] (waitTime [color="#000000"]) {
                                [color="#000080"]return[color="#000000"] [color="#000080"]false[color="#000000"];
                            }
                        }
                    }
                }
                [color="#000080"]catch[color="#000000"] (InterruptedException ex) {
                    notify();
                    [color="#000080"]throw[color="#000000"] ex;
                }
            }
        }
    }
    [color="#000080"]public[color="#000000"] [color="#000080"]synchronized[color="#000000"] [color="#000080"]void[color="#000000"] release() {
        ++[color="#800080"]permits[color="#000000"];
        notify();
    }
    [color="#000080"]public[color="#000000"] [color="#000080"]synchronized[color="#000000"] [color="#000080"]void[color="#000000"] release([color="#000080"]long[color="#000000"] n) {
        [color="#000080"]if[color="#000000"] (n [color="#000000"]) {
            [color="#000080"]throw[color="#000000"] [color="#000080"]new[color="#000000"] IllegalArgumentException([color="#0000ff"]"Negative argument"[color="#000000"]);
        }
        [color="#800080"]permits[color="#000000"] += n;
        [color="#000080"]for[color="#000000"] ([color="#000080"]long[color="#000000"] i = [color="#0000ff"]0[color="#000000"]; i [color="#000000"] permits() {
        [color="#000080"]return[color="#000000"] [color="#800080"]permits[color="#000000"];
    }
}


本文来自ChinaUnix博客，如果查看原文请点：http://blog.chinaunix.net/u/303/showart_12562.html