将方法（或空）传递给Java ArrayList

Question

package asWebRest.shared;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;

public class ThreadRipper {

    private int maxThreads = 4;
    private int maxThreadsHost = 8;


    public void runProcess(String pString) {
        System.out.println(" --> Running [ "+pString+" ]");
        String s = null;
        String[] pArray = { "bash", "-c", pString };
        try { 
            Process p = new ProcessBuilder(pArray).start();
            BufferedReader stdInput = new BufferedReader(new InputStreamReader(p.getInputStream()));
            BufferedReader stdError = new BufferedReader(new InputStreamReader(p.getErrorStream()));
            while ((s = stdInput.readLine()) != null) { System.out.println(s); }
            while ((s = stdError.readLine()) != null) { System.out.println(s); }
            p.destroy();
        }
        catch (IOException e) { e.printStackTrace(); }
        System.out.flush();
    }

    public String runProcesses() {

        boolean pool = false;
        WebCommon wc = new WebCommon();
        ArrayList<Object> threadList = new ArrayList<Object>();
        threadList.add(runProcess("ls -l"));
        threadList.add(runProcess("ls -s"));
        threadList.add(runProcess("ls -al"));

        String runResults = "";
        int procLoop = 0;
        int inPool = 0;

        for(int i = 0; i < threadList.size(); i++) {            
            Object exTask = threadList.get(i);  
            if(!pool) {
                if(inPool < maxThreads) {
                    runResults += "Loop [" + procLoop + "] Thread [" + inPool + "]: " + exTask + "\n";
                    inPool++;
                } else {
                    procLoop++;
                    inPool = 0;
                }
            } else {
                runResults += "Pool Thread [" + inPool + "]: " + exTask + "\n";
                inPool++;
            }       
        }

        return runResults;

    }

    public int getMaxThreads() { return maxThreads; }
    public int getMaxThreadsHost() { return maxThreadsHost; }

}

Answer 1

您所做的是添加runprocess（“ls-l”）的返回，而不是引用runprocess，并且由于runprocess不返回任何内容，Java显示一个错误，您不能将void添加到列表中。

您需要使用runnable的列表。

list processes=new ArrayList ()；

以这种方式将其添加到列表中，

processes.add(()->runprocess（“ls-l”））；

然后您可以使用进程列表执行您选择的任何操作，

for(Runnable process : processes) { 
   process.run();// You can other fancy stuff here.
   new Thread(process).start(); // eg : spawn in new thread.
}