浅谈java.util.concurrent包的并发处理(三)

2014-11-24 09:45:05 · 作者: · 浏览: 2
ava代码
package org.test.concurrent;

import java.util.Calendar;

/** *//**
*

Title: LoonFramework


*

Description:


*

Copyright: Copyright (c) 2007


*

Company: LoonFramework


* @author chenpeng
* @email:ceponline@yahoo.com.cn
* @version 0.1
*/
interface DateTest...{

String getDate();
}

class DateTestImpl implements DateTest...{

private String _date=null;

public DateTestImpl()...{
try...{
_date+=Calendar.getInstance().getTime();
//设定五秒延迟
Thread.sleep(5000);
}catch(InterruptedException e)...{
}
}

public String getDate() ...{

return "date "+_date;
}
}

class DateTestFactory extends FutureProxy...{

@Override
protected DateTest createInstance() ...{
return new DateTestImpl();
}

@Override
protected Class< extends DateTest> getInterface() ...{
return DateTest.class;
}
}

public class Test...{

public static void main(String[] args) ...{

DateTestFactory factory = new DateTestFactory();
DateTest[] dts = new DateTest[100];
for(int i=0;i dts[i]=factory.getProxyInstance();
}
//遍历执行
for(DateTest dt : dts)...{
System.out.println(dt.getDate());
}

}
}
[java]
package org.test.concurrent;

import java.util.Calendar;

/** *//**
*

Title: LoonFramework


*

Description:


*

Copyright: Copyright (c) 2007


*

Company: LoonFramework


* @author chenpeng
* @email:ceponline@yahoo.com.cn
* @version 0.1
*/
interface DateTest...{

String getDate();
}

class DateTestImpl implements DateTest...{

private String _date=null;

public DateTestImpl()...{
try...{
_date+=Calendar.getInstance().getTime();
//设定五秒延迟
Thread.sleep(5000);
}catch(InterruptedException e)...{

}
}

public String getDate() ...{

return "date "+_date;
}
}

class DateTestFactory extends FutureProxy...{

@Override
protected DateTest createInstance() ...{
return new DateTestImpl();
}

@Override
protected Class< extends DateTest> getInterface() ...{
return DateTest.class;
}
}

public class Test...{

public static void main(String[] args) ...{

DateTestFactory factory = new DateTestFactory();
DateTest[] dts = new DateTest[100];
for(int i=0;i dts[i]=factory.getProxyInstance();
}
//遍历执行
for(DateTest dt : dts)...{
System.out.println(dt.getDate());
}

}
}