Многопоточность Java вызывает тупик базы данных (Java 7)

Question

Я хочу создать многопоточный модуль, я установил два класса и дизайн, например:

ThreadConcurrentWoker.class:

public class ThreadConcurrentWoker<E, R> extends ThreadConcurrent<E, R> {

public ThreadConcurrentWoker(List<E> traget, CallableModel<E, R> callable) {
    super.targetList = traget; // a list want to doing in thread.
    super.callable = callable; // Custom callable object
    super.results = new Vector<R>(); // get result in to this list
}

// this is doing Thread method
@Override
public List<R> concurrentExcute() throws Exception {

    ExecutorService executor = Executors.newFixedThreadPool(super.targetList.size());
    CompletionService<R> completionService = new ExecutorCompletionService<R>(executor);
    for (final E elememt : super.targetList) {
        completionService.submit(new Callable<R>() {
            @Override
            public R call() throws Exception {
                callable.setElement(elememt);
                return callable.call();
            }
        });
    }

    int finishs = 0;
    boolean errors = false;

    while (finishs < super.targetList.size() && !errors) {
        Future<R> resultFuture = completionService.take();
        try {
            super.results.add(resultFuture.get());
        } catch (ExecutionException e) {
            errors = true;
        } finally {
            finishs++;
        }
    }
    return super.results;
}

}

CallableModel.class:

public abstract class CallableModel<E, V> implements Callable<V> {
    private E element;

    public E getElement() {
        return element;
    }

    public void setElement(E element) {
        this.element = element;
    }

}

и я хочу использовать вот так:

ThreadConcurrentWoker<FlowPendingCheckedBean, ResultBean> tCUtil = 
new ThreadConcurrentWoker<>(test, new CallableModel<FlowPendingCheckedBean, ResultBean>() {

    @Override
    public ResultBean call() throws Exception {
        // do something in here and return result.
    }

});
try {
    resultBeans = tCUtil.concurrentExcute();
} catch (Exception e1) {
    log.error(e1.getMessage());
}

, но когда я выполню этот класс, он получит одинаковые данные в разных потоках.В результате в базе данных появятся тупики.Как я могу улучшить это?

Answer 1

Я попробовал проблему.Запишите примечания:

Поскольку многопоточность использует один и тот же элемент CallableModel, поэтому, когда первый поток в методе вызова, второй поток в setEelement для изменения элемента, и на этот раз первый поток получит второйэлемент резьбы.