6
मैं कोड निम्नलिखित है:जावा समानांतर फ़ाइल प्रसंस्करण
import java.io.*;
import java.util.concurrent.* ;
public class Example{
public static void main(String args[]) {
try {
FileOutputStream fos = new FileOutputStream("1.dat");
DataOutputStream dos = new DataOutputStream(fos);
for (int i = 0; i < 200000; i++) {
dos.writeInt(i);
}
dos.close(); // Two sample files created
FileOutputStream fos1 = new FileOutputStream("2.dat");
DataOutputStream dos1 = new DataOutputStream(fos1);
for (int i = 200000; i < 400000; i++) {
dos1.writeInt(i);
}
dos1.close();
Exampless.createArray(200000); //Create a shared array
Exampless ex1 = new Exampless("1.dat");
Exampless ex2 = new Exampless("2.dat");
ExecutorService executor = Executors.newFixedThreadPool(2); //Exexuted parallaly to cont number of matches in two file
long startTime = System.nanoTime();
long endTime;
Future<Integer> future1 = executor.submit(ex1);
Future<Integer> future2 = executor.submit(ex2);
int count1 = future1.get();
int count2 = future2.get();
endTime = System.nanoTime();
long duration = endTime - startTime;
System.out.println("duration with threads:"+duration);
executor.shutdown();
System.out.println("Matches: " + (count1 + count2));
startTime = System.nanoTime();
ex1.call();
ex2.call();
endTime = System.nanoTime();
duration = endTime - startTime;
System.out.println("duration without threads:"+duration);
} catch (Exception e) {
System.err.println("Error: " + e.getMessage());
}
}
}
class Exampless implements Callable {
public static int[] arr = new int[20000];
public String _name;
public Exampless(String name) {
this._name = name;
}
static void createArray(int z) {
for (int i = z; i < z + 20000; i++) { //shared array
arr[i - z] = i;
}
}
public Object call() {
try {
int cnt = 0;
FileInputStream fin = new FileInputStream(_name);
DataInputStream din = new DataInputStream(fin); // read file and calculate number of matches
for (int i = 0; i < 20000; i++) {
int c = din.readInt();
if (c == arr[i]) {
cnt++;
}
}
return cnt ;
} catch (Exception e) {
System.err.println("Error: " + e.getMessage());
}
return -1 ;
}
}
कहाँ मैं दो फ़ाइलों के साथ एक सरणी में मैचों की संख्या गिनती करने के लिए कोशिश कर रहा हूँ। अब, हालांकि मैं इसे दो धागे पर चला रहा हूं, कोड अच्छी तरह से नहीं कर रहा है क्योंकि:
(इसे एकल थ्रेड पर चला रहा है, फ़ाइल 1 + फ़ाइल 2 पढ़ने का समय) < (फ़ाइल 1 || फ़ाइल 2 पढ़ने के समय कई धागे में)।
क्या कोई मुझे यह हल करने में मदद कर सकता है (मेरे पास 2 कोर सीपीयू और फ़ाइल का आकार लगभग 1.5 जीबी है)।
@ सूरजचंद्रन, ज्यादातर बार। और वास्तव में कोई प्रभाव नहीं। :) बस एक परीक्षण चलाओ। – Arpssss
फ़ाइलें 1.5 जीबी नहीं हैं, वे केवल ~ 80 के हैं। –
@ किथरंडल, मैं सिर्फ नमूना उपयोग देता हूं। – Arpssss