如何使用 Java 中的两个线程将元素存储在一个数组中？

Question

在我的示例中，我想用 100 到 119 的整数从索引 0 到 19 填充 myArray。

我想同时使用两个线程运行，一个线程将值放在从索引 0 到索引 9 的数组中，另一个线程从索引10 到索引 19。

当我打印出 myArray 的元素时，我希望看到这个：

100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119

但是因为线程同时运行，都可以访问我的值，我得到了错误的结果，这个：

100 101 102 103 104 105 106 107 108 109 100 101 102 103 104 105 106 107 108 109

我认为问题出在我的 addToArray() 方法中，其中线程访问我的 aNumber 变量。

这是我们需要同步的时候吗？如果是，如何？

请看我的代码：

主要class:

public class ThreadMain {
    SimpleThread first;
    SimpleThread second;

    public ThreadMain(String firstName, String secondName) {
        first = new SimpleThread(firstName);
        second = new SimpleThread(secondName);
    }

    public static void main(String[] args) {
        ThreadMain threadMain = new ThreadMain("FirstThread", "SecondThread");
        threadMain.startThreads();
        threadMain.waitForThreadsToFinish();
        threadMain.displayArrayElements();

    }

    private void startThreads() {
        first.start();
        second.start();
    }

    /**
     * main thread sleeps while the other threads are working.
     */
    private void waitForThreadsToFinish() {
        while (first.isAlive() || second.isAlive()) {
            try {
                Thread.sleep(1);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    private void displayArrayElements() {
        for (int i = 0; i < 20; ++i) {
            int element = SimpleThread.getArrayElement(i);
            System.out.println(element);
        }
    }
}

线程 class:

class SimpleThread extends Thread {

    private int startIndex;
    private int endIndex;
    private static int[] myArray = new int[20];
    private int aNumber = 100;

    public SimpleThread(String str) {
        super(str);
    }

    public void run() {

        if (getName().equals("FirstThread")) {
            startIndex = 0;
            endIndex = 10;
            addToArray();//store value of aNumber in myArray from index 0 to index 9.
        }
        if (getName().equals("SecondThread")) {
            startIndex = 10;
            endIndex = 20;
            addToArray();//store value of aNumber in myArray from index 10 to index 19.
        }
    }

    private void addToArray() {
        for (int i = startIndex; i < endIndex; ++i) {
            myArray[i] = aNumber;
            ++aNumber;
        }
    }

    public static int getArrayElement(int index) {
        return myArray[index];
    }
}

Answer 1

您的问题似乎是 SimpleThread 的两个实例都以 100 的起始值开始分配值，然后从那里开始。

实现您想要的结果的一种方法是使用类似的东西：

private void addToArray(int startIndex, int endIndex) {
    for (int i = startIndex; i < endIndex; ++i) {
        myArray[i] = aNumber + startIndex; // Change is here
        ++aNumber;
    }
}

如何使用 Java 中的两个线程将元素存储在一个数组中？

How to store elements in ONE array using TWO threads in Java?

java

arrays

multithreading

synchronized