java阻塞
㈠ java如何實現方法的阻塞
你可以嘗試研究下FutureTask類和Callable介面,他們是一種阻塞線程
舉個例子:
ReceiveThread rt=new ReceiveThread();
FutureTask<String> task=new FutureTask<String>(rt);
Thread t=new Thread(task);
t.start();
String s=task.get();//阻塞方法,只有當Callable里的call方法運算結束,才會解除阻塞
class ReceiveThread implements Callable<String>{
public String call() throws Exception{
while(....){
........
.......
return String;
}
}
}
那你就寫個線程不斷監聽result這個值不就行了,當監聽到的是關閉的值就列印
㈡ java中如何使一個線程進入阻塞態
假設你有一個主線程,線程名為:Thread_A,然後通過Thread_A創建了線程Thread_B、Thread_C,並將線程Thread_B、Thread_C作為局部變數的方式存儲在Thread_A中,並調用Thread_B、Thread_C的start()方法開始執行Thread_B、Thread_C,當Thread_A執行到你要停止的地方就分別調用Thread_B、Thread_C的Wait()方法,使Thread_B、Thread_C暫停,然後線程Thread_A繼續執行,直到Thread_A中調用Thread_B、Thread_C的notify()方法使得Thread_B、Thread_C繼續執行,大體上就是這樣!
㈢ java怎麼寫阻塞式io流,阻塞與非阻塞在寫法上的有什麼區別求大神
首先要明白什麼是「阻塞」?
阻塞實際是針對「當前」線程的一個概念,當前線程可以往下走,就是沒有阻塞,否則就可以說當前線程被阻塞了。
明白了概念就好處理了:
非阻塞:new Thread(){ public void run(){ /* 我的IO處理*/ } }.start()
阻塞:aInputStream.read()這樣就可以了。最簡單的驗證:在main方法中加入這句「System.in.read();」看看你的程序是不是停在這句了?除非你在控制台輸入東西,否則你的程序就「阻塞」在這里了。
㈣ 為何會產生阻塞 java
估計是你之前哪裡調用了類似server.accept之類的代碼,然後就阻塞在那裡了。
把代碼放上來看看。
如果不用線程,主程序在處理一個伺服器和客戶端之間的通信時,沒有處理完就不能去並行處理其他事情,而實際上網路間通信主程序大部分時間是等在那,浪費了系統資源和效率。
也就是說這個通信處理阻塞了主程序在等待的時候去並行處理其他事情。
㈤ Java中阻塞和等待的區別
定義解釋
阻塞:當一個線程試圖獲取一個內部的對象鎖(非java.util.concurrent庫中的鎖),而該鎖被其他線程持有,則該線程進入阻塞狀態。
等待:當一個線程等待另一個線程通知調度器一個條件時,該線程進入等待狀態。例如調用:Object.wait()、Thread.join()以及等待Lock或Condition。
可以通過代碼與JConsole來驗證
驗證阻塞
public static void main(String[] args) throws Exception {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
try {
// 等待主線程獲取鎖
Thread.sleep(10000);
// 請求locker對象的內部鎖
synchronized (locker) {
System.out.println("Get locker");
}
} catch (InterruptedException e) {
// TODO: handle exception
}
}
}, "Blocked Thread");
thread.start();
// 請求locker內部對象鎖
synchronized (locker) {
// 始終持有locker對象的內部鎖
while (true) {
;;
}
}
}
㈥ java中如何編程實現阻塞
自己寫阻塞,就是寫個死循環不斷取參數,當參數條件滿足時就調用相應的方法執行,
具體的執行方法可以交給一個線程來執行
㈦ java線程阻塞問題,怎麼解決
典型地,suspend() 和 resume() 被用在等待另一個線程產生的結果的情形:測試發現結果還沒有產生後,讓線程阻塞,另一個線程產生了結果後,調用 resume() 使其恢復。但suspend()方法很容易引起死鎖問題,已經不推薦使用了。wait() 和 notify() 方法:兩個方法配套使用,wait() 使得線程進入阻塞狀態,它有兩種形式,一種允許 指定以毫秒為單位的一段時間作為參數,另一種沒有參數,前者當對應的 notify() 被調用或者超出指定時間時線程重新進入可執行狀態,後者則必須對應的 notify() 被調用。 初看起來它們與 suspend() 和 resume() 方法對沒有什麼分別,但是事實上它們是截然不同的。區別的核心在於,前面敘述的所有方法,阻塞時都不會釋放佔用的鎖(如果佔用了的話),而這一對方法則相反。 上述的核心區別導致了一系列的細節上的區別。 首先,前面敘述的所有方法都隸屬於 Thread 類,但是這一對卻直接隸屬於 Object 類,也就是說,所有對象都擁有這一對方法。初看起來這十分不可思議,但是實際上卻是很自然的,因為這一對方法阻塞時要釋放佔用的鎖,而鎖是任何對象都具有的,調用任意對象的 wait() 方法導致線程阻塞,並且該對象上的鎖被釋放。而調用 任意對象的notify()方法則導致因調用該對象的 wait() 方法而阻塞的線程中隨機選擇的一個解除阻塞(但要等到獲得鎖後才真正可執行)。 其次,前面敘述的所有方法都可在任何位置調用,但是這一對方法卻必須在 synchronized 方法或塊中調用,理由也很簡單,只有在 synchronized 方法或塊中當前線程才佔有鎖,才有鎖可以釋放。同樣的道理,調用這一對方法的對象上的鎖必須為當前線程所擁有,這樣才有鎖可以釋放。因此,這一對方法調用必須放置在這樣的 synchronized 方法或塊中,該方法或塊的上鎖對象就是調用這一對方法的對象。若不滿足這一條件,則程序雖然仍能編譯,但在運行時會出現IllegalMonitorStateException 異常。 wait() 和 notify() 方法的上述特性決定了它們經常和synchronized 方法或塊一起使用,將它們和操作系統的進程間通信機製作一個比較就會發現它們的相似性:synchronized方法或塊提供了類似於操作系統原語的功能,它們的執行不會受到多線程機制的干擾,而這一對方法則相當於 block 和wakeup 原語(這一對方法均聲明為 synchronized)。它們的結合使得我們可以實現操作系統上一系列精妙的進程間通信的演算法(如信號量演算法),並用於解決各種復雜的線程間通信問題。 關於 wait() 和 notify() 方法最後再說明兩點: 第一:調用 notify() 方法導致解除阻塞的線程是從因調用該對象的 wait() 方法而阻塞的線程中隨機選取的,我們無法預料哪一個線程將會被選擇,所以編程時要特別小心,避免因這種不確定性而產生問題。 第二:除了 notify(),還有一個方法 notifyAll() 也可起到類似作用,唯一的區別在於,調用 notifyAll() 方法將把因調用該對象的 wait() 方法而阻塞的所有線程一次性全部解除阻塞。當然,只有獲得鎖的那一個線程才能進入可執行狀態。 談到阻塞,就不能不談一談死鎖,略一分析就能發現,suspend() 方法和不指定超時期限的 wait() 方法的調用都可能產生死鎖。遺憾的是,Java 並不在語言級別上支持死鎖的避免,我們在編程中必須小心地避免死鎖。 以上我們對 Java 中實現線程阻塞的各種方法作了一番分析,我們重點分析了 wait() 和 notify() 方法,因為它們的功能最強大,使用也最靈活,但是這也導致了它們的效率較低,較容易出錯。實際使用中我們應該靈活使用各種方法,以便更好地達到我們的目的。
㈧ java accept阻塞
這里的API在設計時就是阻塞的,一般這樣用:
server=newServerSocket(8888);//新建服務端監聽
..........................................
while(waitForNewConnet){//判斷是否繼續等待新連接
Sockettemp=server.accept();
newMyConnect(this,temp).start();//在新線程中完成連接的處理,以免阻塞伺服器
writeProxyServerLog("已建立的連接。"+++i);
}
.................
publicMyConnectextendsThread{//處理各種連接
.............................
}
㈨ java如何跳出堵塞
話說只能等待超時,因為你這種連接你不知道它到底是網路延時的問題,還是真的等待,不過你可以把延時時間設置短點
㈩ 在JAVA中Scanner的阻塞是什麼意思
就是等待用戶響應啊,當程序運行到scanner這行代碼的時候需要用戶輸入數據,回車確認輸入,然後程序才會接著根據已有代碼運行並處理用戶輸入的數據。易懂不?不懂再問。