ForkJoinInvoker

ForkJoinInvoker †

ForkJoinInvokerは、JavaでForkJoin?っぽいことを実現するライブラリです.

ソースコード&バイナリ †

ForkJoinInvoker_20170718-001.zip

関数一覧 †

下記の関数の一覧は以下のファイルを参照してください.

 org.loxsols.util.concurrent.forkjoin.ForkJoinInvoker

ForkJoin?メソッド一覧

 // 動的メソッド用.
	public Object[] forkJoin(Object instance, String methodName, List<Object[]> paramsList) throws ForkJoinException;

 // 動的メソッド用( Methodインスタンスを既に生成済みの場合. )
	public Object[] forkJoin(Object instance, Method method, List<Object[]> paramsList) throws ForkJoinException;

 // staticメソッド用.
	public Object[] forkJoin(Class classType, String methodName, List<Object[]> paramsList) throws ForkJoinException;

 // staticメソッド用( Methodインスタンスを既に生成済みの場合. )
	public Object[] forkJoin(Class classType, Method method, List<Object[]> paramsList) throws ForkJoinException;

利用方法 †

ここではSystem.out.println(String)を10回呼び出してみます.

 	public void forkJoinTest001()
	{
		ForkJoinInvoker forkJoinInvoker = new ForkJoinExecutor();
		
		List<Object[]> paramsList = new ArrayList<Object[]>();
		for( int i=0; i < 10; i++)
		{
			Object[] params = new Object[]{ Integer.toString(i) };
			paramsList.add( params );
		}
		try
		{
			forkJoinInvoker.forkJoin( System.out, "println", paramsList );
		}
		catch(Exception e)
		{
			e.printStackTrace();
			Assert.fail();
		}
	}

動作環境 †

・JDK 1.6以上