[imu_1]

I have thousand words in a my arryaList.
I want to distribute them evenly to two processes so that they can process the words.

How can I approach this problem?

[Fuzzyness]

You could always split them into 2 arrays and have each process have its own array?

You have given some really vague information so I cannot give you the best route to take just a general solution.

[imu_1]

Suppose I have amethod called getArray() that returns the arrayList of thousand string words.
Runtime runtime = Runtime.getRuntime();
// Create a child process
Process process = runtime.exec("java subProcess");

OutputStream output = process.getOutputStream();
ObjectOutputStream obj = new ObjectOutputStream(output);
obj.flush();

obj.writeObject(getArray()); // sending the array to the child process for further processing
objos.flush();

As you can see, I am only creating one process and sending the entire doc to it. I would like to create two processes, split the doc into half and send the first half to the first process and second half to the second process.

[blackcompe]

Use ArrayList.subList.

List list = getArrayList();
obj.writeObject(list.subList(list.size()/2, list.size())); 

If you're trying to improve performance by calling another process, consider using multi-threading, especially since you can't guarantee the 'java' command will execute on the user's machine.

[macosxnerd101]

Just to be picky here: List list = getArrayList();, the List should be declared using generics to avoid a deprecation warning.

[CasiOo]

Why dont you just start two threads ?? It would be much easier

[imu_1]

I have gotten this far now:

 
    			  List list = load.getFile(); 
			
	                   int begin = 0; 
			
			for(int i = 1; i <= num; i++)
			 { 
			    end = (list.size()/num) *i;
				
			    process[i] = rt.exec("java subProcess"); 
			// get an ObjectOutputStream for sending data to the child 
	         OutputStream os = process[i].getOutputStream();
	         ObjectOutputStream obj = new ObjectOutputStream(os);
             obj.flush();  // outputs the bytes to another outputstream 
               System.out.println("Parent sending: " + list.subList(begin, end));
				// send the ArrayList to the child
	           objos.writeObject(list.subList(begin, end)); 
			   obj.flush();
              begin = end+1; 
			  
			}

I am however getting this error:



C:\JAVA>java MultiProcess
Enter the number of processes : 2

Parent sending: [child, mango, orange, zebra, theory, tomato]
java.io.NotSerializableException: java.util.RandomAccessSubList
at java.io.ObjectOutputStream.writeObject0(Unknown Source)
at java.io.ObjectOutputStream.writeObject(Unknown Source)
at MultiProcess.main(MultiProcess.java:49)

It doesnt allow me to sned the data to the child process. Why ?

This post has been edited by imu_1: 31 January 2012 - 06:39 PM

[blackcompe]

List.subList returns an implementation that's hidden from the client. Unfortunately, it's not serializable, meaning it can be sent through a stream. You need to use a serializable list.

ArrayList lst = new ArrayList(list.subList(begin, end));
objos.writeObject(lst); 

This post has been edited by blackcompe: 31 January 2012 - 06:53 PM

[imu_1]

thanks man