743
JAVA異步調用
就是A調用一個係統的工作流，係統工作流做完反饋B，這是一個異步的過程。現在想做成同步的，就是A啟動工作流之後停止，一直等待B被回調了，設定超時時間，如果超時A返回錯誤；否則返回成功。
B每次收到請求就往裏麵加數據
A如果非超時處理完請求就會把數據刪掉
A這邊設置一個集合
隻有集合裏有工單ID了才返回結果，並且把這個ID從集合中REMOVE調
B一來A就ADD一個
A如果非超時處理完請求就會把數據刪掉
A這邊設置一個集合
隻有集合裏有工單ID了才返回結果，並且把這個ID從集合中REMOVE調
B一來A就ADD一個
public class AClient2C2 {
private final long timeout = 10000;
public void test(String taskId) {
long count = 0;
while (BService2C2.getInstance().isHasTask(taskId) && count < timeout) {
try {
System.out.println("wait+"+count);
Thread.sleep(1000);
count += 1000;
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(count>=timeout) {
System.out.println("超時");
}
}
public static void main(String[] args){
BService2C2.getInstance().regesitTaskId("aaaa");
AClient2C2 ac = new AClient2C2();
ac.test("aaaa");
BService2C2.getInstance().removeTaskId("aaaa");
}
}
import java.util.HashMap;
import java.util.Map;
public class BService2C2 {
private static BService2C2 instance;
private static Map<String,String> map = new HashMap<String,String>();
private BService2C2() {
}
public static BService2C2 getInstance(){
if(instance==null){
instance = new BService2C2();
}
return instance;
}
public void regesitTaskId(String taskId){
map.put(taskId, taskId);
}
public void removeTaskId(String taskId){
map.remove(taskId);
}
public boolean isHasTask(String taskId){
if(null!=map.get(taskId)){
return Boolean.TRUE;
}
return Boolean.FALSE;
}
}
最後更新：2017-04-03 18:52:01