实例展示Java多线程编程问题

原创 àì夳堔傛蜴生んèń 2024-09-25 03:24 57阅读 0赞

在Java中，多线程编程主要通过Thread类和Runnable接口实现。以下是一个简单的多线程编程问题示例：

**问题：**

你有一个任务，需要对一个数组进行排序。但是，你想使用多线程来加速这个过程。

现在，你需要编写一个名为`SortArrayParallel`的Java方法，该方法接受一个未排序的整数数组作为参数，并使用多线程来完成排序任务。

**示例代码：**

```java
import java.util.Arrays;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class SortArrayParallel {
    public static void main(String[] args) {
        int[] arr = {5, 2, 8, 1, 9};
        
        ExecutorService executor = Executors.newFixedThreadPool(4); // 创建线程池

// 将排序任务提交给线程池
        for (int i : arr) {
            executor.submit(new SortTask(i)); // SortTask是负责排序的类
        }

// 关闭线程池，释放资源
        executor.shutdown();
        while (!executor.isTerminated())) {
            System.out.println("仍有任务在执行...");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        
        // 打印排序后的数组
        System.out.println("Sorted array:");
        System.out.println(Arrays.toString(arr));
    }

// 定义一个负责排序任务的类
    private static class SortTask implements Runnable {
        private int value;

public SortTask(int value) {
            this.value = value;
        }

@Override
        public void run() {
            // 实现排序逻辑，这里简单地交换位置
            int temp = value;
            value = arr[arr.indexOf(value) - 1]];
            arr[arr.indexOf(temp) - 1]] = value;

// 当任务完成时，通知主线程
            System.out.println("Task " + value + " completed.");
        }
    }
}
```

这个示例中，`SortArrayParallel`方法接收一个数组并创建一个新的线程池。然后，将每个元素作为一个任务提交给线程池。每个任务负责对数组中的一个元素进行排序。

当所有任务完成时，主线程会打印出排序后的数组。