蝸牛的JAVA外殼

┎Running Snail┒ ┖ -------------- ┚

BlogJava :: 首頁 :: 聯系 :: 聚合

:: 管理

13 Posts :: 0 Stories :: 10 Comments :: 0 Trackbacks

Java單線程阻塞解決方案

我寫了一個Feed提取小程序，但有時由于Feed長時間無響應，所以需要去判斷是否超時，以下的程序
主線程：

package test.thread;
2

import com.sun.syndication.feed.synd.SyndFeed;
4

public class RssThread extends Thread {
6

public void run() {
8

while(true)
9

{
10

try
11

{
12

System.out.println("start");
14

String[] str = new String[]{"http://del.icio.us/rss/geneboy",
16

"http://picasaweb.google.com/data/feed/base/user/icyleaf.cn",
17

"http://feeds.qzone.qq.com/cgi-bin/cgi_rss_out?uin=414680"};
18

for( int i = 0 ; i < str.length ; i++ )
20

{
21

System.out.println("url = " + str[i]);
22

RssUtil ru = new RssUtil();
24

ru.setUrl(str[i]);
25

ru.start();
26

while(true)
28

{
29

sleep(2000);
30

SyndFeed feed = ru.getFeed();
31

System.out.println("feed = " + (feed != null ? "ok" : "timeOut"));
32

if ( feed == null )
34

{
35

sleep(10000);
36

feed = ru.getFeed();
38

System.out.println("second feed = " + (feed != null ? "ok" : "timeOut"));
39

}
40

if ( feed == null )
42

{
43

break;
44

}
45

else
46

{
47

System.out.println("處理不null");
48

break;
49

}
50

}
51

}
52

System.out.println("end");
54

sleep(2000);
56

}catch(Exception e)
58

{
59

//e.printStackTrace();
60

}
61

}
62

}
63

public static void main(String[] args)
65

{
66

RssThread rss = new RssThread();
67

rss.start();
68

}
69

}
70

RssUtil：負責提取Rss

package test.thread;
2

import java.net.URL;
4

import org.apache.commons.logging.Log;
6

import org.apache.commons.logging.LogFactory;
7

import com.sun.syndication.feed.synd.SyndFeed;
9

import com.sun.syndication.io.SyndFeedInput;
10

import com.sun.syndication.io.XmlReader;
11

/**
13

* Rss相關
14

*
15

* @author Administrator
16

*
17

*/
18

public class RssUtil extends Thread {
19

private String url;
21

private SyndFeed feed;
23

private static final Log logger = LogFactory.getLog(RssUtil.class);
25

public void run() {
27

feed = getFeed(url);
29

}
30

/**
32

* 獲得Feed
33

*
34

* @param url
35

* @return
36

*/
37

public SyndFeed getFeed(String url) {
38

try
39

{
40

URL feedUrl = new URL(url);
41

SyndFeedInput input = new SyndFeedInput();
42

SyndFeed feed = input.build(new XmlReader(feedUrl));
44

return feed;
46

} catch (Exception ex) {
48

//ex.printStackTrace();
49

}
50

return null;
52

}
53

public SyndFeed getFeed() {
55

return feed;
56

}
57

public void setFeed(SyndFeed feed) {
59

this.feed = feed;
60

}
61

public String getUrl() {
63

return url;
64

}
65

public void setUrl(String url) {
67

this.url = url;
68

}
69

}
70

posted on 2008-01-09 16:31 會跑的蝸牛閱讀(1952) 評論(0) 編輯收藏所屬分類: Java

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: Java單線程阻塞解決方案 [原創]Java設計模式之單態[學習中]

蝸牛的JAVA外殼

常用鏈接

留言簿(1)

我參與的團隊

隨筆分類

隨筆檔案

搜索

最新評論

閱讀排行榜

評論排行榜