Java多线程简单实例

一时失言乱红尘 2022-06-14 00:19 359阅读 0赞

最近为了提高批处理程序的统计效率，将程序改为多线程执行，由原来的单一线程计算改为五个线程同时计算，大大缩短了统计时间。实现原理很简单，就是将需要计算的内容分成五份交给五个线程进行统计，五个线程相互之间没有影响。

程序

public class GenerateMonitorCompanyAndPersonRisk implements Runnable{
    
    	private List<SysAccount> accountList;
    	
    	public GenerateMonitorCompanyAndPersonRisk(List<SysAccount> accountList) {
    		this.accountList = accountList;
    	}
    
    	@Override
    	public void run() {
    		MonitorCompanyService monitorCompanyService = new MonitorCompanyService();
    		
    		MonitorCompanyRiskAnalysisService monitorCompanyRiskAnalysisService = new MonitorCompanyRiskAnalysisService();
    		
    		MonitorRelationCompanyRiskAnalysisService monitorRelationCompanyRiskAnalysisService = new MonitorRelationCompanyRiskAnalysisService();
    		
    		MonitorRelationPersonRiskAnalysisService monitorRelationPersonRiskAnalysisService = new MonitorRelationPersonRiskAnalysisService();
    		
    		MonitorRelationCompanyService monitorRelationCompanyService = new MonitorRelationCompanyService();
    		
    		MonitorRiskReportService monitorRiskReportService = new MonitorRiskReportService();
    		
    		MonitorRelationPersonService monitorRelationPersonService = new MonitorRelationPersonService();
    		
    		MonitorUserEventLevelCompanyNumTrendService monitorUserEventLevelCompanyNumTrendService = new MonitorUserEventLevelCompanyNumTrendService();
    		
    		String accountId = "";
    		
    		for(SysAccount account : accountList){
    			accountId = account.getAccountId();
    			
    			//生成监控企业风险分析
    			monitorCompanyRiskAnalysisService.generateMonitorCompanyRiskAnalysis(accountId);
    			
    			//生成关系企业风险分析
    			monitorRelationCompanyRiskAnalysisService.generateMonitorRelationCompanyRiskAnalysis(accountId);
    			
    			//生成关系个人风险分析
    			monitorRelationPersonRiskAnalysisService.generateMonitorRelationPersonRiskAnalysis(accountId);
    			
    			//更新关系企业风险信息
    			monitorRelationCompanyService.updateMonitorRelationCompanyRisk(accountId);
    			
    			//更新关系自然人风险信息
    			monitorRelationPersonService.updateMonitorRelationPersonRisk(accountId);
    			
    			//更新动态监控企业风险信息
    			monitorCompanyService.updateMonitorCompanyRisk(accountId);
    			
    			//生成用户动态监控各事件类型企业数量趋势
    			monitorUserEventLevelCompanyNumTrendService.generateMonitorUserEventLevelCompanyNumTrend(accountId);
    			
    			//统计动态监控风险报告
    			monitorRiskReportService.generateMonitorRiskReport(accountId);
    		}
    	}
    	
    	public static void main(String[] args) {
    		SysAccountService sysAccountService = new SysAccountService();
    		
    		MonitorCompanyEventService monitorCompanyEventService = new MonitorCompanyEventService();
    		
    		MonitorPersonEventService monitorPersonEventService = new MonitorPersonEventService();
    		
    		//获取企业和个人的风险事件
    		monitorCompanyEventService.getTodayCompanyEvent();
    		
    		monitorPersonEventService.getTodayPersonEvent();
    		
    		//获取所有有效的账号
    		List<SysAccount> accountList = sysAccountService.queryEffectiveSysAccount();
    		
    		//分五个线程统计风险信息
    		int num = accountList.size() / 4;
    		
    		List<SysAccount> accountList1 = accountList.subList(0, num*1);
    		List<SysAccount> accountList2 = accountList.subList(num*1, num*2);
    		List<SysAccount> accountList3 = accountList.subList(num*2, num*3);
    		List<SysAccount> accountList4 = accountList.subList(num*3, num*4);
    		List<SysAccount> accountList5 = accountList.subList(num*4, accountList.size()); 
    		
    		GenerateMonitorCompanyAndPersonRisk generator1 = new GenerateMonitorCompanyAndPersonRisk(accountList1);
    		GenerateMonitorCompanyAndPersonRisk generator2 = new GenerateMonitorCompanyAndPersonRisk(accountList2);
    		GenerateMonitorCompanyAndPersonRisk generator3 = new GenerateMonitorCompanyAndPersonRisk(accountList3);
    		GenerateMonitorCompanyAndPersonRisk generator4 = new GenerateMonitorCompanyAndPersonRisk(accountList4);
    		GenerateMonitorCompanyAndPersonRisk generator5 = new GenerateMonitorCompanyAndPersonRisk(accountList5);
    		
    		Thread thread1 = new Thread(generator1);
    		Thread thread2 = new Thread(generator2);
    		Thread thread3 = new Thread(generator3);
    		Thread thread4 = new Thread(generator4);
    		Thread thread5 = new Thread(generator5);
    		
    		thread1.start();
    		thread2.start();
    		thread3.start();
    		thread4.start();
    		thread5.start();
    	}
    }

这里没有涉及到线程的同步、阻塞等等，所以很容易实现。我是通过实现Runnable接口来实现多线程的，相对继承Thread类有以下几个优点：  
1）：适合多个相同的程序代码的线程去处理同一个资源  
2）：可以避免java中的单继承的限制  
3）：增加程序的健壮性，代码可以被多个线程共享，代码和数据独立。