java - 为我的多线程代码寻求改进建议。我需要12个不同的任务，6个池大小和15分钟的调度程序

Question

Closed. This question needs to be more focused。它当前不接受答案。












想改善这个问题吗？更新问题，使其仅通过 editing this post专注于一个问题。

3天前关闭。



Improve this question





我需要创建一个多线程程序，以6个池的大小来实现12个不同的任务（例如，任务1从文件读取，任务2处理一些数据，任务3序列化一些对象等），并使用ExecutorService每15分钟安排一次。我已经做到了，而且似乎也可以。但是我只需要即兴发挥自己，就问这个问题。
尊敬的观众，如果您有任何代码块建议来改进此程序，或者我做错了任何事情，请告诉我。我还有一个问题，如何测试给定数量的池大小是否确实有效？

public class ScheduledThreadClass {
    static Set<Runnable> setOfRunnables = new HashSet<Runnable>();
    static ScheduledFuture scheduledFuture = null;

    public static void main(String[] args) {
        runnableSet();
        scheduledExecution();
    }

    public static void scheduledExecution() {
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(6);

        for (Runnable runnable : setOfRunnables) {
            scheduledFuture = scheduledExecutorService.scheduleAtFixedRate(runnable, 5, 15, TimeUnit.MINUTES);
        }
    }

    public static void runnableSet() {

        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-1");
            }
        });
        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-2");
            }
        });
        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-3");
            }
        });
        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-4");
            }
        });

        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-5");
            }
        });
        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-6");
            }
        });
        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-7");
            }
        });
        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-8");
            }
        });
        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-9");
            }
        });
        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-10");
            }
        });
        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-11");
            }
        });
        setOfRunnables.add(new Runnable(){
            public void run(){
                System.out.println("task-12");
            }
        });
    }
}

最佳答案

如果您使用的是Java 8或更高版本，建议您使用lambda而不是new Runnable()。

在您的情况下，它会导致类似：

public class ScheduledThreadClass {
    static Set<Runnable> setOfRunnables = new HashSet<>();
    static ScheduledFuture scheduledFuture = null;

    public static void main(String[] args) {
        runnableSet();
        scheduledExecution();
    }

    public static void scheduledExecution() {
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(6);

        for (Runnable runnable : setOfRunnables) {
            scheduledFuture = scheduledExecutorService.scheduleAtFixedRate(runnable, 5, 15, TimeUnit.MINUTES);
        }
    }

    public static void runnableSet() {
        setOfRunnables.add(() -> System.out.println("task-1"));
        setOfRunnables.add(() -> System.out.println("task-2"));
        setOfRunnables.add(() -> System.out.println("task-3"));
        setOfRunnables.add(() -> System.out.println("task-4"));

        setOfRunnables.add(() -> System.out.println("task-5"));
        setOfRunnables.add(() -> System.out.println("task-6"));
        setOfRunnables.add(() -> System.out.println("task-7"));
        setOfRunnables.add(() -> System.out.println("task-8"));
        setOfRunnables.add(() -> System.out.println("task-9"));
        setOfRunnables.add(() -> System.out.println("task-10"));
        setOfRunnables.add(() -> System.out.println("task-11"));
        setOfRunnables.add(() -> System.out.println("task-12"));
    }
}

其背后的主要原因（除了较少的冗长性）是它遵循当前的 best practices，因为它遵循功能性编程逻辑。

如果需要，还可以向它们添加主体：

setOfRunnables.add(() -> {
    System.out.println("task-1");
});

关于java - 为我的多线程代码寻求改进建议。我需要12个不同的任务，6个池大小和15分钟的调度程序，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/62409196/

上一篇：character-encoding - 低级字符编码如何工作？

下一篇：java - 在带有泛型参数的泛型方法中使用 Spring RestTemplate

相关文章：

java - Android:从另一个打开 fragment

java - 如何以编程方式在 Eclipse 插件中添加右键菜单

java - Java编译中错误的意外顺序

java - 基于运行时条件的 Spring 开关实现

ios - 在后台线程上保存到 CoreData Context

c - c - 如何退出或停止正在运行的线程？

java - Tomcat 内存使用量在 IDLE 中增长

java - 通过调用start()和run()来运行线程，有什么区别？

c# - IIS 工作线程与 Web 应用程序线程

c++ - 使用 OpenMP 实现的线程池

Answer 1

如果您使用的是Java 8或更高版本，建议您使用lambda而不是new Runnable()。

在您的情况下，它会导致类似：

public class ScheduledThreadClass {
    static Set<Runnable> setOfRunnables = new HashSet<>();
    static ScheduledFuture scheduledFuture = null;

    public static void main(String[] args) {
        runnableSet();
        scheduledExecution();
    }

    public static void scheduledExecution() {
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(6);

        for (Runnable runnable : setOfRunnables) {
            scheduledFuture = scheduledExecutorService.scheduleAtFixedRate(runnable, 5, 15, TimeUnit.MINUTES);
        }
    }

    public static void runnableSet() {
        setOfRunnables.add(() -> System.out.println("task-1"));
        setOfRunnables.add(() -> System.out.println("task-2"));
        setOfRunnables.add(() -> System.out.println("task-3"));
        setOfRunnables.add(() -> System.out.println("task-4"));

        setOfRunnables.add(() -> System.out.println("task-5"));
        setOfRunnables.add(() -> System.out.println("task-6"));
        setOfRunnables.add(() -> System.out.println("task-7"));
        setOfRunnables.add(() -> System.out.println("task-8"));
        setOfRunnables.add(() -> System.out.println("task-9"));
        setOfRunnables.add(() -> System.out.println("task-10"));
        setOfRunnables.add(() -> System.out.println("task-11"));
        setOfRunnables.add(() -> System.out.println("task-12"));
    }
}

其背后的主要原因（除了较少的冗长性）是它遵循当前的 best practices，因为它遵循功能性编程逻辑。

如果需要，还可以向它们添加主体：

setOfRunnables.add(() -> {
    System.out.println("task-1");
});