JPPF笔记

1. 参数传递：Job.setDataProvider 传递给Task?

?

2. 初始化例子

?

?

public void run() {

ApplicationContext ctx = (ApplicationContext) NodeRunner.getPersistentData("spring-context");

if (ctx == null) {

ctx = ?new MyContext("classpath:applicationContext.xml");

System.out.println("get context");

NodeRunner.setPersistentData("spring-context", ctx);

}

JdbcTemplate jdbc = (JdbcTemplate) ctx.getBean("jdbcTemplate");

List list = jdbc.queryForList("select * from um_usr");

System.out.println(list.size());

super.setResult(1000L);

}

?

3. Concurrent 包

JPPF实现了Java5 Concurrent包

但是因为JPPF采用远程传输方式，所以任务类必须实现Serializable 接口，否则收不到计算结果。

?

测试Main:

public static void main(String[] args) throws InterruptedException, ExecutionException {

JPPFClient client = new JPPFClient();

JPPFExecutorService exec = new JPPFExecutorService(client);

Future<Long> future = exec.submit(new MyTask());

System.out.println("future get:" + future.get());

exec.shutdown();

}

?

public class MyTask implements Callable<Long>, Serializable {

?

private static final long serialVersionUID = -4442750246804487036L;

?

@Override

public Long call() throws Exception {

System.out.println("running me ..");

return 100L;

}

?

}