download:人人都能学会数据分析【16周完结】
package com.zzger.model;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import com.zzger.module.queue.UrlQueue;
import com.zzger.util.HttpUtils;
import com.zzger.util.RegexUtils;
public class WebSite {
/**
* 站点url
*/
private String url;
/**
* 须要匍匐的url队列
*/
private UrlQueue<String> urls = new UrlQueue<>();
/**
* 已匍匐过的页面url
*/
private List<String> exitUrls = Collections.synchronizedList(new ArrayList<>());
private static final int TOTAL_THREADS = 12;
private final CountDownLatch mStartSignal = new CountDownLatch(1);
private final CountDownLatch mDoneSignal = new CountDownLatch(TOTAL_THREADS);
public WebSite(String url){
this.url = url;
urls.offer(url);//把网站首页退出须要匍匐的队列中
}
public void guangDu(){
new Thread(new Runnable() {
@Override
public void run() {
paxing(HttpUtils.httpGet(url));
}
}).start();
}
public void paxing(String html){
if(html.lastIndexOf("下一页</a></li></ul></div>")<0) return ;
String strList = html.substring(html.indexOf("<li class=\\"next-page\\">"),
html.lastIndexOf("下一页</a></li></ul></div>"));
String url = RegexUtils.RegexString("<a href=\\"(.+?)\\"", strList);
if(url.equals("Nothing")) return ;
urls.put(url);//把url存储到队列中
paxing(HttpUtils.httpGet(url));
}
public void dxcPx(){
Page<DuanZi> page = new Gxpage(urls.take());
List<Section<DuanZi>> list = page.ybhqSection().getSections();
for(Section<DuanZi> section : list){
new Thread(new Runnable() {
@Override
public void run() {
mStartSignal.countDown();// 计数减一为0,工作线程真正启动具体操作
try {
mStartSignal.await();// 阻塞,期待mStartSignal计数为0运行前面的代码
// 所有的工作线程都在期待同一个启动的命令
} catch (InterruptedException e) {
e.printStackTrace();
}
DuanZi duanzi = section.select().getModel();
System.out.println(duanzi.getTitle());
mDoneSignal.countDown();// 实现当前计数减一
}
}
).start();
}
try
{
mDoneSignal.await();// 期待所有工作线程完结
}
catch (InterruptedException e)
{
e.printStackTrace();
}
dxcPx();//线程工作执行完后,再次获取url队列进行工作
}
public static void main(String[] args) {
WebSite web = new WebSite("http://duanziwang.com");
web.guangDu();
for(int i = 0; i<10;i++){
new Thread(new Runnable() {
@Override
public void run() {
web.dxcPx();
}
}).start();
}
}
}
发表回复