此篇文章主要是练习一下多线程,有业务需求,有多根光纤需要扫描,要求使用多线程.
代码都包含注释,不详细说了,直接贴代码了.
ScanResult.java
package com.xinguo.myspring.util; /** * 扫描结果封装成的对象 * @Title: ScanResult * @Package com.xinguo.myspring.util * @Description: * @author butingyou@gtstart.com.cn * @date Mar 19, 2014 1:16:41 PM * @version V1.0 */ public class ScanResult { private String dataFileName;//扫描完成生成的数据文件 private String fiberId;//扫描的光纤ID public ScanResult(String dataFileName, String fiberId) { super(); this.dataFileName = dataFileName; this.fiberId = fiberId; } public String getDataFileName() { return dataFileName; } public String getFiberId() { return fiberId; } public void setDataFileName(String dataFileName) { this.dataFileName = dataFileName; } public void setFiberId(String fiberId) { this.fiberId = fiberId; } }
FiberScanServiceImpl.java
package com.xinguo.myspring.util; /** * 扫描的最底层类,此类调用真实扫描方法 * @Title: FiberScanServiceImpl * @Package com.xinguo.myspring.util * @Description: 现实中可能用到通信,获取消息等 * @author butingyou@gtstart.com.cn * @date Mar 19, 2014 1:19:52 PM * @version V1.0 */ public class FiberScanServiceImpl { /** * 扫描 * @Title: scan * @Description: * @param @param fiberId * @param @return * @return String * @throws */ public String scan(String fiberId) { String dataFileName = ""; try { System.out.println(Thread.currentThread().getName() + ",扫描光纤[" + fiberId + "]开始"); //模拟扫描消耗的时间 Thread.sleep(10000); System.out.println(Thread.currentThread().getName() + ",扫描光纤[" + fiberId + "]结束"); //模拟文件格式 dataFileName = "192.168.4.12_20140319_" + fiberId + ".sorda"; } catch (InterruptedException e) { e.printStackTrace(); } return dataFileName; } }
Scanner.java
这个类稍微说一下,实现了Callable接口,实现了call()方法,这个方法有返回值,是Java 5以后新增的.想再了解些请浏览http://blog.csdn.net/ghsau/article/details/7451464
package com.xinguo.myspring.util; import java.util.concurrent.Callable; /** * 实现Callable接口的线程类 * * @Title: Scanner * @Package com.xinguo.myspring.util * @Description: 实现Callable接口,返回扫描结果对象 * @author butingyou@gtstart.com.cn * @date Mar 19, 2014 1:26:34 PM * @version V1.0 */ public class Scanner implements Callable<ScanResult> { private String fiberName; private FiberScanServiceImpl scanServiceImpl = new FiberScanServiceImpl(); public Scanner(String fiberName) { super(); this.fiberName = fiberName; } public ScanResult call() throws Exception { String dataFile = scanServiceImpl.scan(fiberName); ScanResult scanResult = new ScanResult(dataFile, fiberName); return scanResult; } public String getFiberName() { return fiberName; } public void setFiberName(String fiberName) { this.fiberName = fiberName; } }
MutilThreadTest.java
测试类.
package com.xinguo.myspring.util; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; /** * 多线程测试 * * @Title: MutilThreadTest * @Package com.xinguo.myspring.util * @Description: 模拟光纤扫描过程,根据光纤个数创建多个线程执行扫描工作 * @author butingyou@gtstart.com.cn * @date Mar 19, 2014 11:19:28 AM * @version V1.0 */ public class MutilThreadTest { // 光纤条数 private static String[] fiber = { "F1", "F2", "F3", "F4" }; public static void main(String[] args) { try { //初始化指定个数的线程池 ExecutorService pool = Executors.newFixedThreadPool(fiber.length); for (int i = 0; i < fiber.length; i++) { Callable<ScanResult> callable = new Scanner(fiber[i]); //用Future<V>接收线程返回的扫描结果对象 Future<ScanResult> future = pool.submit(callable); ScanResult scanResult = future.get(); System.out.println("扫描光纤" + fiber[i] + "得到的数据文件是:" + scanResult.getDataFileName()); } System.out.println(Thread.currentThread().getName() + ",end............,关闭线程池."); //关闭线程池 pool.shutdown(); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } }
测试结果:
pool-1-thread-1,扫描光纤[F1]开始 pool-1-thread-1,扫描光纤[F1]结束 扫描光纤F1得到的数据文件是:192.168.4.12_20140319_F1.sorda pool-1-thread-2,扫描光纤[F2]开始 pool-1-thread-2,扫描光纤[F2]结束 扫描光纤F2得到的数据文件是:192.168.4.12_20140319_F2.sorda pool-1-thread-3,扫描光纤[F3]开始 pool-1-thread-3,扫描光纤[F3]结束 扫描光纤F3得到的数据文件是:192.168.4.12_20140319_F3.sorda pool-1-thread-4,扫描光纤[F4]开始 pool-1-thread-4,扫描光纤[F4]结束 扫描光纤F4得到的数据文件是:192.168.4.12_20140319_F4.sorda main,end............,关闭线程池.
相关推荐
Pker多线程后台急速扫描器,扫描网站敏感地址。
Pker多线程后台极速扫描工具2.01修正版
Pker多线程后台极速扫描工具.zip 。
多线程磁盘文件扫描
多线程扫描端口多线程扫描端口多线程扫描端口多线程扫描端口多线程扫描端口多线程扫描端口
多线程网站后台扫描工具1.3 1.两种扫描模式:线程扫描 普通扫描 2.程序会检测robots.txt存在提示查看 3.可自行外挂后台地址字典 4.可添加排除关键字 1.2更新:2008.04.22 修正部分目录无法正常扫描出来 1.3更新:...
包括如下功能:按照IP地址进行端口扫描,按照给定的IP地址范围,逐个进行扫描、按照主机名进行端口扫描,搜索指定主机名的端口、指定扫描的端口范围、指定扫描的线程数,实现多线程扫描、保存扫描结果,将端口扫描的...
本程序利用了Java多线程进行了TCP的端口扫描,能够满足一般的业务需求,适用与网管或网络安全从事者
基于多线程的端口扫描器,包含源代码以及分析
linux下多线程是想操作系统的经典生产者和消费者模拟实验。用C语言编写,gcc能够编译。而且含有makefile文件的解释。
多线程模拟进程调度多线程模拟进程调度多线程模拟进程调度多线程模拟进程调度
多线程Shell资源扫描器 哇嘎网络安全小组
可扫描网站后台 一个多线程的后台管理扫描器 两种扫描模式:线程扫描 普通扫描
多线程TCP端口扫描器源码,win32程序。
python多线程批量端口扫描,代码里自己可设定端口范围。
多线程MAC地址扫描,易语言例程。局域网取IP地址!!
低积分下载,恶心一下那些搬运资源还要高积分的。声明:资源为转载资源,只用于技术交流,请勿使用在违法道路上。
本软件是用java开发的多线程端口扫描器。可以实现本地扫描和指定IP扫描。本文包含文档说明和代码,很详细。
易语言多线程端口扫描源码,多线程端口扫描,开始扫描,连接客户1