そこで、独立した暗号化プロセスを並列化するために、次の単純なクラスを実装しました。
public class SelectionEncryptor implements Callable<BigInteger> {
private DamgardJurik dj;
private byte c;
private int s;
public SelectionEncryptor(DamgardJurik dj, byte c, int s) {
this.dj = dj;
this.c = c;
this.s = s;
}
@Override
public BigInteger call() throws Exception {
dj.setS(s);
BigInteger r = dj.encryption(BigInteger.valueOf(c));
System.out.println("dj s: " + dj.s + ", given s: " + s + ", c: " + c);
return r;
}
}
sは、使用する暗号システムのパラメータにすぎませんが、暗号化の深さを決定する重要なものです。
次のようにスレッドを初期化して実行します。
int s = s_max;
ExecutorService executor = Executors.newFixedThreadPool(selectionBits.length);
ArrayList<Future<BigInteger>> list = new ArrayList<Future<BigInteger>>();
// selectionBits is just a byte array holding 1's and 0's
for (int i = 0; i < selectionBits.length; i++) {
dj.setS(s);
SelectionEncryptor se = new SelectionEncryptor(dj, selectionBits[i], s);
System.out.println("submitted: " + selectionBits[i] + " with s " + s + ", dj s: " + dj.s);
Future<BigInteger> result = executor.submit(se);
list.add(result);
s--;
}
// collecting results
for (Future<BigInteger> future : list) {
try {
BigInteger f = future.get();
out.println(f);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
}
executor.shutdown();
問題は、正しいs値を SelectionEncryptor に送信しても、異なる値を使用するだけです。これは私のプログラムの出力例です:
submitted: 1 with s 6, dj s: 6
submitted: 0 with s 5, dj s: 6
submitted: 1 with s 4, dj s: 5
submitted: 0 with s 3, dj s: 3
submitted: 1 with s 2, dj s: 2
submitted: 0 with s 1, dj s: 1
dj s: 4, given s: 1, c: 0
dj s: 2, given s: 2, c: 1
dj s: 2, given s: 3, c: 0
dj s: 2, given s: 4, c: 1
dj s: 2, given s: 6, c: 1
dj s: 2, given s: 5, c: 0
メイン関数でのみ、呼び出し可能なクラスでのみsを設定しようとしましたが、安全のために両方に設定していますが、まだ機能していません。
この問題の原因は何ですか? これらの呼び出し可能なインスタンスは DamgardJurick オブジェクトを共有していますか? 私は何が欠けていますか?
長い質問で申し訳ありませんが、簡単にする方法が見つかりませんでした。