日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

java+synchro_synchrozied,wait()与notify()的理解

發布時間:2024/10/8 编程问答 37 豆豆
生活随笔 收集整理的這篇文章主要介紹了 java+synchro_synchrozied,wait()与notify()的理解 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

public class TestWait{

private List list = new ArrayList();

public TestWait(){

}

public synchronized Object get(){

System.out.println(Thread.currentThread()+"進入了...");

while(list.isEmpty()){

System.out.println(Thread.currentThread()+"在等待.....");

try{

//list為空,線程掛起,并釋放出對象鎖,從而讓下一個線程進入該安全方法?wait();

}catch(Exception

e){

e.printStackTrace();

};

}

Object o = list.get(0);

list.remove(0);

return o;

}

public synchronized void put(){

System.out.println(Thread.currentThread()+"在加了一個值...");

list.add("nnn");

System.out.println("喚醒線程..");

//將wait的線程喚醒

notifyAll();?}

public static void

main(String[] args){

try{

TestWait tw =

new TestWait();

new

ThreadA(tw).start();

new

ThreadB(tw).start();

new

ThreadA(tw).start();

new

ThreadB(tw).start();

}catch(Exception?e){

e.printStackTrace();

};

}

}

class ThreadA extends Thread{

TestWait tw = null;

public ThreadA(TestWait tw){

this.tw = tw;

}

public void run(){

for(int i=0;i<10;i++){

try{

System.out.println(Thread.currentThread()+"取到了值:"+tw.get());

sleep(100);

tw.put();

}catch(Exception

e){

e.printStackTrace();

}

}

}

}

class ThreadB extends Thread{

TestWait tw = null;

public ThreadB(TestWait tw){

this.tw = tw;

}

public void run(){

for(int i=0;i<10;i++){

try{

sleep(100);

}catch(Exception

e){

e.printStackTrace();

}

tw.put();

}

}

}

####測試內容如下

Thread[Thread-0,5,main]進入了...

Thread[Thread-0,5,main]在等待.....

Thread[Thread-2,5,main]進入了...

Thread[Thread-2,5,main]在等待.....

Thread[Thread-1,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]取到了值:nnn

Thread[Thread-0,5,main]在等待.....

Thread[Thread-3,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]取到了值:nnn

Thread[Thread-1,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]進入了...

Thread[Thread-2,5,main]取到了值:nnn

Thread[Thread-3,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]進入了...

Thread[Thread-0,5,main]取到了值:nnn

Thread[Thread-2,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]進入了...

Thread[Thread-2,5,main]取到了值:nnn

Thread[Thread-1,5,main]在加了一個值...

喚醒線程..

Thread[Thread-3,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]進入了...

Thread[Thread-0,5,main]取到了值:nnn

Thread[Thread-2,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]進入了...

Thread[Thread-2,5,main]取到了值:nnn

Thread[Thread-1,5,main]在加了一個值...

喚醒線程..

Thread[Thread-3,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]進入了...

Thread[Thread-0,5,main]取到了值:nnn

Thread[Thread-1,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]進入了...

Thread[Thread-2,5,main]取到了值:nnn

Thread[Thread-0,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]進入了...

Thread[Thread-0,5,main]取到了值:nnn

Thread[Thread-3,5,main]在加了一個值...

喚醒線程..

Thread[Thread-1,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]進入了...

Thread[Thread-2,5,main]取到了值:nnn

Thread[Thread-0,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]進入了...

Thread[Thread-0,5,main]取到了值:nnn

Thread[Thread-3,5,main]在加了一個值...

喚醒線程..

Thread[Thread-1,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]進入了...

Thread[Thread-2,5,main]取到了值:nnn

Thread[Thread-0,5,main]在加了一個值...

喚醒線程..

Thread[Thread-3,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]進入了...

Thread[Thread-0,5,main]取到了值:nnn

Thread[Thread-1,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]進入了...

Thread[Thread-2,5,main]取到了值:nnn

Thread[Thread-3,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]進入了...

Thread[Thread-0,5,main]取到了值:nnn

Thread[Thread-1,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]進入了...

Thread[Thread-2,5,main]取到了值:nnn

Thread[Thread-3,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]進入了...

Thread[Thread-0,5,main]取到了值:nnn

Thread[Thread-1,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]在加了一個值...

喚醒線程..

Thread[Thread-2,5,main]進入了...

Thread[Thread-2,5,main]取到了值:nnn

Thread[Thread-3,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]進入了...

Thread[Thread-0,5,main]取到了值:nnn

Thread[Thread-2,5,main]在加了一個值...

喚醒線程..

Thread[Thread-0,5,main]在加了一個值...

喚醒線程..

######jdk1.5以后的版本

ReentrantLock也能得到以上結果,如下

import java.util.ArrayList;

import java.util.List;

import java.util.concurrent.locks.*;

public class TestWaitjdk15{

private List list = new ArrayList();

//鎖

private ReentrantLock lock = new

ReentrantLock();

//條件 相當于之前的 wait 與 notify;

Condition con?=

lock.newCondition();

public TestWaitjdk15(){

}

public?Object get(){

lock.lock();

try{

System.out.println(Thread.currentThread()+"進入了...");

while(list.isEmpty()){

System.out.println(Thread.currentThread()+"在等待.....");

try{

//list為空,線程掛起,并釋放出對象鎖,從而讓下一個線程進入該安全方法?con.await();

}catch(Exception

e){

e.printStackTrace();

};

}

Object o = list.get(0);

list.remove(0);

return o;

}finally{

lock.unlock();

}

}

public?void put(){

lock.lock();

try{

System.out.println(Thread.currentThread()+"在加了一個值...");

list.add("nnn");

System.out.println("喚醒線程..");

//將wait的線程喚醒

con.signalAll();

}finally{

lock.unlock();

}

}

public static void main(String[] args){

try{

TestWaitjdk15

tw = new TestWaitjdk15();

new

ThreadC(tw).start();

new

ThreadD(tw).start();

new

ThreadC(tw).start();

new

ThreadD(tw).start();

}catch(Exception?e){

e.printStackTrace();

};

}

}

class ThreadC extends Thread{

TestWaitjdk15 tw = null;

public ThreadC(TestWaitjdk15 tw){

this.tw = tw;

}

public void run(){

for(int i=0;i<10;i++){

try{

System.out.println(Thread.currentThread()+"取到了值:"+tw.get());

sleep(100);

tw.put();

}catch(Exception

e){

e.printStackTrace();

}

}

}

}

class ThreadD extends Thread{

TestWaitjdk15 tw = null;

public ThreadD(TestWaitjdk15 tw){

this.tw = tw;

}

public void run(){

for(int i=0;i<10;i++){

try{

sleep(100);

}catch(Exception

e){

e.printStackTrace();

}

tw.put();

}

}

}

總結

以上是生活随笔為你收集整理的java+synchro_synchrozied,wait()与notify()的理解的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。