liquanyu / regional-platform

Authored by yangfei over 8 years ago

Showing 3 changed files with 59 additions and 0 deletions

	1	+package com.lyms.platform.operate.web;
	2	+
	3	+import java.util.concurrent.ExecutorService;
	4	+import java.util.concurrent.Executors;
	5	+import java.util.concurrent.TimeUnit;
	6	+
	7	+/**
	8	+ * @auther yangfei
	9	+ * @createTime 2017年10月25日 18时00分
	10	+ * @discription
	11	+ */
	12	+public class ThreadPoolTest {
	13	+ public static void main(String[] args) {
	14	+ //固定线程数量的线程池
	15	+ ExecutorService threadPool = Executors.newFixedThreadPool(3); //线程池的大小依赖于操作系统（或者说JVM）
	16	+ // ExecutorService threadPool = Executors.newCachedThreadPool(); //单个线程的线程池：只有一个线程在工作，如果这个线程异常结束，则会立刻有一个新线程替代它
	17	+ // ExecutorService threadPool = Executors.newSingleThreadExecutor();
	18	+ for (int i = 1; i <= 10; i++) {
	19	+ final int task = i;
	20	+ threadPool.execute(new Runnable() {
	21	+ @Override
	22	+ public void run() {
	23	+ for (int j = 1; j <= 10; j++) {
	24	+ try {
	25	+ Thread.sleep(20);
	26	+ } catch (InterruptedException e) { // TODO Auto-generated catch block
	27	+
	28	+ e.printStackTrace();
	29	+ }
	30	+ System.out.println(Thread.currentThread().getName() + " is looping of " + j + " for task of " + task);
	31	+ }
	32	+ }
	33	+ });
	34	+ }
	35	+ threadPool.shutdown();
	36	+ //结束线程池
	37	+ // 附带一个定时任务，O(∩_∩)O哈哈~
	38	+ Executors.newScheduledThreadPool(3).scheduleAtFixedRate(new Runnable() {
	39	+ @Override
	40	+ public void run() {
	41	+ System.out.println("bombing!");
	42	+ }
	43	+ }, 6, 2, TimeUnit.SECONDS);
	44	+
	45	+ }
	46	+}

...	...	@@ -54,6 +54,9 @@
54	54	private String registerAddr;
55	55	//居住地
56	56	private String addr;
	57	+ //街道/
	58	+ private String street;
	59	+
57	60	//首次建档医院
58	61	private String firstBH;
59	62	//分娩医院
...	...	@@ -82,6 +85,14 @@
82	85	return SPIT;
83	86	}
84	87	return tireNumber;
	88	+ }
	89	+
	90	+ public String getStreet() {
	91	+ return street;
	92	+ }
	93	+
	94	+ public void setStreet(String street) {
	95	+ this.street = street;
85	96	}
86	97
87	98	public void setTireNumber(String tireNumber) {

...	...	@@ -101,6 +101,8 @@
101	101	} catch (Exception e) {
102	102	chanResult.setFirstBH("");
103	103	}
	104	+ //乡镇/街道
	105	+ chanResult.setStreet(CommonsHelper.getName1(patients.getStreetId(),basicConfigService));
104	106	MatDeliverQuery matDeliverQuery = new MatDeliverQuery();
105	107	matDeliverQuery.setPid(patients.getPid());
106	108	matDeliverQuery.setCreatedStart(patients.getLastMenses());