Java单线程阻塞解决方案

?

转至:http://www.blogjava.net/unser/archive/2008/01/09/174052.html

?

一个Feed提取小程序，但有时由于Feed长时间无响应，所以需要去判断是否超时，以下的程序
主线程：

?1package?test.thread;
?2
?3import?com.sun.syndication.feed.synd.SyndFeed;
?4
?5public?class?RssThread?extends?Thread?{
?6????
?7????public?void?run()?{
?8????????while(true)
?9????????{
10????????????try
11????????????{
12????????????????
13????????????????System.out.println("start");
14????????????????
15????????????????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????????????????
19????????????????for(?int?i?=?0?;?i?<?str.length?;?i++?)
20????????????????{
21????????????????????System.out.println("url?=?"?+?str[i]);
22
23????????????????????RssUtil?ru?=?new?RssUtil();
24????????????????????ru.setUrl(str[i]);
25????????????????????ru.start();
26????????????????????
27????????????????????while(true)
28????????????????????{
29????????????????????????sleep(2000);
30????????????????????????SyndFeed?feed?=?ru.getFeed();
31????????????????????????System.out.println("feed?=?"?+?(feed?!=?null???"ok"?:?"timeOut"));
32????????????????????????
33????????????????????????if?(?feed?==?null?)
34????????????????????????{
35????????????????????????????sleep(10000);
36????????????????????????????
37????????????????????????????feed?=?ru.getFeed();
38????????????????????????????System.out.println("second?feed?=?"?+?(feed?!=?null???"ok"?:?"timeOut"));
39????????????????????????}????????????????????????????
40????????????????????????
41????????????????????????if?(?feed?==?null?)
42????????????????????????{
43????????????????????????????break;
44????????????????????????}
45????????????????????????else
46????????????????????????{
47????????????????????????????System.out.println("处理不null");
48????????????????????????????break;
49????????????????????????}
50????????????????????}
51????????????????}
52????????????????
53????????????????System.out.println("end");
54????????????????
55????????????????sleep(2000);
56????????????????
57????????????}catch(Exception?e)
58????????????{
59????????????????//e.printStackTrace();
60????????????}
61????????}????????
62????}
63????
64????public?static?void?main(String[]?args)
65????{
66????????RssThread?rss?=?new?RssThread();
67????????rss.start();
68????}
69}
70

RssUtil：负责提取Rss

?1package?test.thread;
?2
?3import?java.net.URL;
?4
?5import?org.apache.commons.logging.Log;
?6import?org.apache.commons.logging.LogFactory;
?7
?8import?com.sun.syndication.feed.synd.SyndFeed;
?9import?com.sun.syndication.io.SyndFeedInput;
10import?com.sun.syndication.io.XmlReader;
11
12/**
13?*?Rss相关
14?*?
15?*?@author?Administrator
16?*?
17?*/
18public?class?RssUtil?extends?Thread?{
19????
20????private?String?url;
21????
22????private?SyndFeed?feed;
23
24????private?static?final?Log?logger?=?LogFactory.getLog(RssUtil.class);
25????
26????public?void?run()?{
27????????
28????????feed?=?getFeed(url);
29????}
30
31????/**
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
43????????????SyndFeed?feed?=?input.build(new?XmlReader(feedUrl));
44
45????????????return?feed;
46????????????
47????????}?catch?(Exception?ex)?{
48????????????//ex.printStackTrace();
49????????}
50
51????????return?null;
52????}
53
54????public?SyndFeed?getFeed()?{
55????????return?feed;
56????}
57
58????public?void?setFeed(SyndFeed?feed)?{
59????????this.feed?=?feed;
60????}
61
62????public?String?getUrl()?{
63????????return?url;
64????}
65
66????public?void?setUrl(String?url)?{
67????????this.url?=?url;
68????}
69}

<!--EndFragment-->