0

クラスの2つのメソッドを呼び出すJavaコードがあります。次のように、

import java.io.*;
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 < 100 ; i++){
dos.writeInt(i);
}
dos.close();

FileOutputStream fos1 = new FileOutputStream("2.dat");
DataOutputStream dos1 = new DataOutputStream(fos1);

for(int i =100 ; i < 200 ; i++){
dos1.writeInt(i);
}
dos1.close();


Exampless ex = new Exampless();
ex.createArray(0);
ex.ReadData("1.dat");
ex.ReadData("2.dat");

    }catch (Exception e){
  System.err.println("Error: " + e.getMessage());
  }
  }
}

class Exampless{

public static int []arr = new int [100] ;
void createArray(int z){
    for(int i =z ; i < z+100 ; i++)
        arr[i-z] = i ;
}
public synchronized void ReadData(String name){
  try{
int cnt = 0;
 FileInputStream fin = new FileInputStream(name);
DataInputStream din = new DataInputStream(fin);
for(int i = 0 ; i < 100 ; i++){
int c = din.readInt();
if(c == arr[i])
cnt++ ;
}

System.out.println("File name: " + name + " No. of Matches: " + cnt) ;
    }catch (Exception e){
  System.err.println("Error: " + e.getMessage());
  }
  }
}

最初の方法では、コードは共有配列を作成し、2番目の方法ではそれをファイルと比較します。

ReadData()ここで、複数のスレッドを使用して、これら2つのメソッドを並行して実行したいと思います。誰かが私がそれをするのを手伝ってくれる？おそらくいくつかのコード変更があります。

4

3 に答える 3

2 
import java.io.*;
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 < 100; i++) {
            dos.writeInt(i);
        }
        dos.close();

        FileOutputStream fos1 = new FileOutputStream("2.dat");
        DataOutputStream dos1 = new DataOutputStream(fos1);

        for (int i = 100; i < 200; i++) {
            dos1.writeInt(i);
        }
        dos1.close();

        Exampless.createArray(0); //static method call to set the static arr variable
        Exampless ex1 = new Exampless("1.dat");
        Exampless ex2 = new Exampless("2.dat");
        Thread t1 = new Thread(ex1);
        Thread t2 = new Thread(ex2);
        t1.start(); //calls the run method in ex1 in a new thread
        t2.start();

    } catch (Exception e) {
        System.err.println("Error: " + e.getMessage());
    }
}
}

class Exampless implements Runnable {

public static int[] arr = new int[100];
public String _name;

public Exampless(String name) {
    this._name = name;
}

static void createArray(int z) {
    for (int i = z; i < z + 100; i++) {
        arr[i - z] = i;
    }
}

@Override
public void run() {
    try {
        int cnt = 0;
        FileInputStream fin = new FileInputStream(_name);
        DataInputStream din = new DataInputStream(fin);
        for (int i = 0; i < 100; i++) {
            int c = din.readInt();
            if (c == arr[i]) {
                cnt++;
            }
        }
        System.out.println("File name: " + _name + " No. of Matches: " + cnt);
    } catch (Exception e) {
        System.err.println("Error: " + e.getMessage());
    }
}

}
于 2012-07-29T18:25:56.940 に答える
0

クラスに「実行可能」を実装させ、2 つのインスタンスを作成して実行します。

于 2012-07-29T18:14:49.907 に答える
0

別のスレッドでの呼び出し中に配列を変更しない限り、ReadData同期せずにそのままにしておくことができます。
より優れたより堅牢な方法は、アレイへのアクセスを同期することです。 

import java.io.*;
class Exampless {

    private static int[] arr = new int[100];
    private static ReadWriteLock lock = new ReentrantReadWriteLock();

    void createArray(int z) {
        lock.writeLock().lock();
        try {
        for (int i = z; i < z + 100; i++)
            arr[i - z] = i;
        } finally {
            lock.writeLock().unlock();
        }
    }

    void ReadData(String name) {
        lock.readLock().lock();
        try {
            int cnt = 0;
            FileInputStream fin = new FileInputStream(name);
            DataInputStream din = new DataInputStream(fin);
            for (int i = 0; i < 100; i++) {
                int c = din.readInt();
                if (c == arr[i])
                    cnt++;
            }

            System.out
                    .println("File name: " + name + " No. of Matches: " + cnt);
        } catch (Exception e) {
            System.err.println("Error: " + e.getMessage());
        } finally {
            lock.readLock().unlock();
        }
    }
}
于 2012-07-29T18:18:04.483 に答える