java.util.ConcurrentModificationException -- 执行 IO 操作时的错误(不带列表)

Jo *_*mma 2 java android concurrentmodification android-intentservice

好的。这是场景。我有一个用户填写的表单来创建一个 Match 对象。我使用 anIntentService将信息写入后台线程上的文件。如果在boolean中传递了“true”的intenta,则ScoreFile也写入了相应的 a 。GlobalMatch是一个单例对象这里是IntentService代码:

 public class WriteMatchService extends IntentService {

        private static final String EXTRA_SCORES_FILE = "scores_file";
        public static final String REFRESH_MATCH_LIST_INTENT_FILTER = "refresh_match_list";

        public static Intent getIntent(Context context, boolean writeScoresFile) {
            Intent intent = new Intent(context.getApplicationContext(),
                    WriteMatchService.class);
            intent.putExtra(EXTRA_SCORES_FILE, writeScoresFile);
            return intent;
        }

        public WriteMatchService() {
            super("WriteMatchService");
        }

        @Override
        protected void onHandleIntent(@Nullable Intent intent) {

            boolean writeScoresFile = false;

            if (intent != null) {
                if (intent.hasExtra(EXTRA_SCORES_FILE)) {
                    writeScoresFile = intent.getBooleanExtra(EXTRA_SCORES_FILE, false);
                }
            } else {
                // this should never happen
                return;
            }

            Context context = getApplicationContext();
            // globalMatch is a singleton object
            GlobalMatch globalMatch = GlobalMatch.getInstance(context);
            Match match = globalMatch.getCurrentMatch();

            if (writeScoresFile) {
                FileUtils.writeScoresFile(context, new ScoresFile(match.getMatchId()));
            }

            FileUtils.writeMatchToFile(context, match);

            // notify the match list to reload its contents if necessary
            Intent messageIntent = new Intent(REFRESH_MATCH_LIST_INTENT_FILTER);
            LocalBroadcastManager manager = LocalBroadcastManager.getInstance(getApplicationContext());
            manager.sendBroadcast(messageIntent);

        }
    }
Run Code Online (Sandbox Code Playgroud)

下面是编写 Match 文件和 Scores 文件的两种方法:

匹配文件:

public static void writeMatchToFile(Context context, Match match) {

        File file = new File(context.getFilesDir(), Match.getFileName(match.getMatchId().toString()));
        String jsonString = "";
        FileOutputStream fos = null;
        jsonString = new Gson().toJson(match);

        try {
            fos = context.openFileOutput(file.getName(), Context.MODE_PRIVATE);
            fos.write(jsonString.getBytes());
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if (fos != null) {
                    fos.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        // after creating match, make it the current one
        SharedPreferences.Editor editor = context.getSharedPreferences(MY_GLOBAL_MATCH,
                Context.MODE_PRIVATE).edit();
        editor.putString(CURRENT_MATCH, jsonString);
        editor.apply();
    }
Run Code Online (Sandbox Code Playgroud)

匹配对象包含一个Stage对象列表。

这是匹配类:

public class Match implements Parcelable {

    private static final String TAG = "Match";

    private UUID mMatchId;
    private String mClubId;
    private String mMatchName;
    private Date mMatchDate;
    private MatchLevel mMatchLevel;
    private List<Stage> mStages;
    private List<Competitor> mCompetitors;
    private String mPassword;
    private MatchType mMatchType;

    public enum MatchType {
        USPSA("USPSA"), ACTION_STEEL("Action Steel");

        private String name;

        MatchType(String name) {
            this.name = name;
        }

        @Override
        public String toString() {
            return name;
        }
    }

    private enum MatchLevel {
        I("I"), II("II"), III("III"), IV("IV"), V("V");

        private String value;

        MatchLevel(String value){
            this.value = value;
        }

        @Override
        public String toString() {
            return value;
        }
    }

    // no arg constructor, most likely to be used as initial match created upon installation
    public Match() {

        Calendar calendar = Calendar.getInstance();
        calendar.setTime(new Date());
        mMatchDate = calendar.getTime();
        mMatchType = MatchType.USPSA;
        mMatchId = UUID.randomUUID();
        mMatchName = "";
        mMatchLevel = MatchLevel.I;
        mClubId = "";
        mStages = new ArrayList<>();
        mCompetitors = new ArrayList<>();
        mPassword = "";
    }

    public Match(String matchName, Date matchDate, MatchLevel matchLevel, MatchType matchType, String clubID, String password) {

        mMatchId = UUID.randomUUID();
        mClubId = clubID;
        mMatchName = matchName;
        mMatchDate = matchDate;
        mMatchLevel = matchLevel;
        mMatchType = matchType;
        mStages = new ArrayList<>();
        mCompetitors = new ArrayList<>();
        mPassword = password;
    }

    public String getPassword() {
        return mPassword;
    }

    public void setPassword(String password) {
        mPassword = password;
    }

    public UUID getMatchId() {
        return mMatchId;
    }

    public String getClubId() {
        return mClubId;
    }

    public void setClubId(String clubId) {
        mClubId = clubId;
    }

    public String getMatchName() {
        return mMatchName;
    }

    public void setMatchName(String matchName) {
        mMatchName = matchName;
    }

    public Date getMatchDate() {
        return mMatchDate;
    }

    public void setMatchDate(Date matchDate) {
        mMatchDate = matchDate;
    }

    public MatchLevel getMatchLevel() {
        return mMatchLevel;
    }

    public String getMatchLevelString() {
        return mMatchLevel.toString();
    }

    public void setMatchLevel(MatchLevel matchLevel) {
        mMatchLevel = matchLevel;
    }

    public void setMatchLevel(String str){
        switch (str){
            case "I":
                mMatchLevel = MatchLevel.I;
                break;
            case "II":
                mMatchLevel = MatchLevel.II;
                break;
            case "III":
                mMatchLevel = MatchLevel.III;
                break;
            case "IV":
                mMatchLevel = MatchLevel.IV;
                break;
            case "V":
                mMatchLevel = MatchLevel.V;
                break;
            default:
                Log.d(TAG, "Something went wrong");
        }
    }

    public MatchType getMatchType() {
        return mMatchType;
    }

    public static MatchType getMatchTypeFromString(String matchType){
        switch (matchType){
            case "USPSA":
                return MatchType.USPSA;
            case "Action Steel":
                return MatchType.ACTION_STEEL;
            default:
                return null;
        }
    }

    public String getMatchTypeString(){
        return mMatchType.toString();
    }

    public void setMatchType(MatchType matchType){ mMatchType = matchType;}

    public void setMatchType(String matchType) {
        switch (matchType){
            case "USPSA":
                mMatchType = MatchType.USPSA;
                break;
            case "Action Steel":
                mMatchType = MatchType.ACTION_STEEL;
                break;
            default:
                Log.d(TAG, "Something went wrong");
        }
    }

    public void addStage(Stage stage) {
        mStages.add(stage);
    }

    public List<Stage> getStages() {
        return mStages;
    }

    public void setStages(List<Stage> stages) {
        mStages = stages;
    }

    public List<Competitor> getCompetitors() {
        return mCompetitors;
    }

    public void setCompetitors(List<Competitor> competitors) {
        mCompetitors = competitors;
    }

    public void addCompetitor(Competitor competitor) {
        // if adding a competitor here, assign the competitor a shooter number
        competitor.setShooterNum(mCompetitors.size() + 1);
        mCompetitors.add(competitor);
    }

    public void updateCompetitorInMatch(Competitor comp) {

        for (Competitor c : mCompetitors) {
            // this works because both will have the same ID
            if (c.equals(comp) && (c.getShooterNum() == comp.getShooterNum())) {
                mCompetitors.remove(c);
                mCompetitors.add(comp);
                break;
            }
        }
    }

    public void updateStageInMatch(Stage stage){
        for (Stage s : mStages){
            if(stage.equals(s)){
                mStages.remove(s);
                mStages.add(stage);
                break;
            }
        }
    }


    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        Match match = (Match) o;
        return Objects.equals(mMatchId, match.mMatchId);
    }

    @Override
    public int hashCode() {
        return 7 * mMatchId.hashCode();
    }

    public static String getFileName(String matchID) {
        return "match." + matchID + ".json";
    }

    public static String formatMatchDate(Date date){

        return (String) DateFormat.format("MM/dd/yyyy", date);
    }


    @Override
    public int describeContents() {
        return 0;
    }

    @Override
    public void writeToParcel(Parcel dest, int flags) {
        dest.writeSerializable(this.mMatchId);
        dest.writeString(this.mClubId);
        dest.writeString(this.mMatchName);
        dest.writeLong(this.mMatchDate != null ? this.mMatchDate.getTime() : -1);
        dest.writeInt(this.mMatchLevel == null ? -1 : this.mMatchLevel.ordinal());
        dest.writeTypedList(this.mStages);
        dest.writeTypedList(this.mCompetitors);
        dest.writeString(this.mPassword);
        dest.writeInt(this.mMatchType == null ? -1 : this.mMatchType.ordinal());
    }

    protected Match(Parcel in) {
        this.mMatchId = (UUID) in.readSerializable();
        this.mClubId = in.readString();
        this.mMatchName = in.readString();
        long tmpMMatchDate = in.readLong();
        this.mMatchDate = tmpMMatchDate == -1 ? null : new Date(tmpMMatchDate);
        int tmpMMatchLevel = in.readInt();
        this.mMatchLevel = tmpMMatchLevel == -1 ? null : MatchLevel.values()[tmpMMatchLevel];
        this.mStages = in.createTypedArrayList(Stage.CREATOR);
        this.mCompetitors = in.createTypedArrayList(Competitor.CREATOR);
        this.mPassword = in.readString();
        int tmpMMatchType = in.readInt();
        this.mMatchType = tmpMMatchType == -1 ? null : MatchType.values()[tmpMMatchType];
    }

    public static final Creator<Match> CREATOR = new Creator<Match>() {
        @Override
        public Match createFromParcel(Parcel source) {
            return new Match(source);
        }

        @Override
        public Match[] newArray(int size) {
            return new Match[size];
        }
    };
}
Run Code Online (Sandbox Code Playgroud)

这是Stage我收集字段并创建 IntentService的表单文件部分:

{
                    mStage.setTime(Double.valueOf(mTime.getText().toString()));
                    mStage.setScoringType(Stage.getScoringTypeFromString(mScoringTypeSpinner.getSelectedItem().toString()));
                    mStage.setSteelTargets(Integer.valueOf(mSteelTargets.getText().toString()));
                    mStage.setSteelNPMs(Integer.valueOf(mSteelNPMs.getText().toString()));
                    mStage.setNoShoots(mNoShoots.isChecked());

                    mStage.setRounds(mStage.getNumberOfSteelTargets());
                    mStage.setPoints(mStage.getNumberOfSteelTargets() * 5);


                    // if creating a new stage include a stage number in the stage name
                    if (!mEditing) {
                        int stageNum = (mMatch.getStages().size() + 1);
                        mStage.setStageNum(stageNum);
                        mStage.setStageName("Stage " + stageNum + ": " + mStageName.getText().toString());
                        mMatch.addStage(mStage);

                        Intent serviceIntent = WriteMatchService.getIntent(mContext, false);
                        mContext.startService(serviceIntent);

                    } else if (mEditing) {
                        // if editing an existing stage, only edit the part of the name after the stage number
                        mStage.setStageName(getNamePrefix(mStage.getStageName()) + mStageName.getText().toString());
                        mMatch.updateStageInMatch(mStage);

                        Intent serviceIntent = WriteMatchService.getIntent(mContext, false);
                        mContext.startService(serviceIntent);
                    }
                }
Run Code Online (Sandbox Code Playgroud)

服务启动后,我将用户发送到不同的 Fragment。注意:该服务应该运行得非常快。我一直在收到 java.util.ConcurrentModificationException,但只是偶尔一次。这不会每次都发生。我无法确定为什么会收到此错误。Android Studio 将我指向方法中的“ jsonString = new Gson().toJson(match);”行WriteMatchToFile(Context, Match)。我错过了什么?

这是显示错误的堆栈跟踪部分:

    --------- beginning of crash
2018-11-25 11:20:30.194 13665-13777/com.patgekoski.ez_score E/AndroidRuntime: FATAL EXCEPTION: IntentService[WriteMatchService]
    Process: com.patgekoski.ez_score, PID: 13665
    java.util.ConcurrentModificationException
        at java.util.ArrayList$Itr.next(ArrayList.java:860)
        at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.write(CollectionTypeAdapterFactory.java:96)
        at com.google.gson.internal.bind.CollectionTypeAdapterFactory$Adapter.write(CollectionTypeAdapterFactory.java:61)
        at com.google.gson.internal.bind.TypeAdapterRuntimeTypeWrapper.write(TypeAdapterRuntimeTypeWrapper.java:69)
        at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$1.write(ReflectiveTypeAdapterFactory.java:127)
        at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.write(ReflectiveTypeAdapterFactory.java:245)
        at com.google.gson.Gson.toJson(Gson.java:704)
        at com.google.gson.Gson.toJson(Gson.java:683)
        at com.google.gson.Gson.toJson(Gson.java:638)
        at com.google.gson.Gson.toJson(Gson.java:618)
        at com.patgekoski.ez_score.util.FileUtils.writeMatchToFile(FileUtils.java:75)
        at com.patgekoski.ez_score.services.WriteMatchService.onHandleIntent(WriteMatchService.java:63)
        at android.app.IntentService$ServiceHandler.handleMessage(IntentService.java:76)
        at android.os.Handler.dispatchMessage(Handler.java:106)
        at android.os.Looper.loop(Looper.java:164)
        at android.os.HandlerThread.run(HandlerThread.java:65)
2018-11-25 11:20:30.198 1699-13283/system_process W/ActivityManager:   Force finishing activity com.patgekoski.ez_score/.StagesListActivity
Run Code Online (Sandbox Code Playgroud)

小智 5

正如您所提到的,该Match对象包含一个List<Stage>

匹配对象包含舞台对象列表。

问题是在Gson#toJson()处理您的Match对象并将其转换为 JSON 时,它还必须List<Stage>使用迭代器迭代并处理它们。有时(当您的应用程序失败时),迭代器正被 Gson 用于转换过程,另一个线程会修改 ,List<Stage>因为它恰好是Singleton的嵌套字段。next()在 Gson 的方法中调用的迭代器的方法ConcurrentModificationException如果从列表中获取迭代器后列表已被修改,则抛出。

解决方案
您希望如何处理此故障取决于您的应用程序的性质(文件的保存方式)。

解决方案之一是使用 aCopyOnWriteArrayList将Stage对象存储在您的Match对象中。它使用 List 的副本作为Iterator. 对实际列表的修改不会影响Iterator.

另一个可能是synchronise将Match对象写入文件并修改它们的方法。

有关s 以及如何避免它们的更多信息,请参阅此帖子ConcurrentModificationException。