如何将这个简单的Spark Streaming代码转换成多线程代码？

import org.apache.spark.SparkConf;
import org.apache.spark.streaming.Duration;
import org.apache.spark.streaming.api.java.JavaDStream;
import org.apache.spark.streaming.api.java.JavaStreamingContext;

public class SparkStreamingMultiThreadExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建SparkConf对象
        SparkConf conf = new SparkConf().setAppName("SparkStreamingMultiThreadExample").setMaster("local[2]");

        // 创建JavaStreamingContext对象
        JavaStreamingContext jssc = new JavaStreamingContext(conf, new Duration(1000));

        // 创建多个线程处理数据流
        int numThreads = 3;
        JavaDStream<String> lines = jssc.socketTextStream("localhost", 9999);
        JavaDStream<String>[] splitLines = lines.repartition(numThreads).randomSplit(new double[numThreads]);

        for (int i = 0; i < numThreads; i++) {
            final int threadIndex = i;
            JavaDStream<String> threadStream = splitLines[i];
            threadStream.foreachRDD(rdd -> {
                rdd.foreachPartition(partitionOfRecords -> {
                    // 在每个分区上创建Spark任务
                    while (partitionOfRecords.hasNext()) {
                        String record = partitionOfRecords.next();
                        // 处理数据
                        System.out.println("Thread " + threadIndex + ": " + record);
                    }
                });
            });
        }

        // 启动Spark Streaming
        jssc.start();
        jssc.awaitTermination();
    }
}