有没有一种方法可以在可调用的方法中接受一个参数?

50
我已经创建了一段代码,它接受一个IP地址(从另一个类的主方法中)并循环遍历一系列IP地址,在此过程中对每个地址进行ping操作。我有一个GUI前端,由于程序崩溃,我使用了多线程技术。我的问题是,在ping代码中,由于其可调用性,我无法再将IP地址作为参数传递。我已经搜索了所有相关内容,但似乎找不到解决方法。是否有办法让可调用方法接受参数?如果没有,是否有其他方法可以实现我想要做的事情?
我代码的示例:
public class doPing implements Callable<String>{

public String call() throws Exception{

    String pingOutput = null;

    //gets IP address and places into new IP object
    InetAddress IPAddress = InetAddress.getByName(IPtoPing);
    //finds if IP is reachable or not. a timeout timer of 3000 milliseconds is set.
    //Results can vary depending on permissions so cmd method of doing this has also been added as backup
    boolean reachable = IPAddress.isReachable(1400);

    if (reachable){
          pingOutput = IPtoPing + " is reachable.\n";
    }else{
        //runs ping command once on the IP address in CMD
        Process ping = Runtime.getRuntime().exec("ping " + IPtoPing + " -n 1 -w 300");
        //reads input from command line
        BufferedReader in = new BufferedReader(new InputStreamReader(ping.getInputStream()));
        String line;
        int lineCount = 0;
        while ((line = in.readLine()) != null) {
            //increase line count to find part of command prompt output that we want
            lineCount++;
            //when line count is 3 print result
            if (lineCount == 3){
                pingOutput = "Ping to " + IPtoPing + ": " + line + "\n";
            }
        }
    }
    return pingOutput;
}
}

以前使用IPtoPing作为参数。

8个回答

71

由于方法签名不允许,您无法将其作为参数传递给call()

但是,您可以通过构造函数参数传递必要的信息;例如:

public class DoPing implements Callable<String>{
    private final String ipToPing;

    public DoPing(String ipToPing) {
        this.ipToPing = ipToPing;
    }

    public String call() throws SomeException {
        InetAddress ipAddress = InetAddress.getByName(ipToPing);
        ....
    }
}

(我纠正了一些极其严重的代码风格违规!!)

有一些方法可以消除上述代码中的一些“样板”编码(请参见其他答案)。 在这种情况下,我们正在谈论4行代码(在约40行的类中),因此我并不认为它值得一试。(但是嘿,这是你的代码。)

或者,您可以:

  • 将DoPing声明为内部类(或lambda),并使其引用封闭范围中的final ipToPing,或者

  • 添加一个setIpToPing (String ipToPing)方法。

(后者允许重复使用DoPing对象,但缺点是您需要同步才能以线程安全的方式访问它。)


8

由于方法签名不允许,您无法向call()传递参数,但至少有一种方法可以解决这个问题:

  1. 定义一个抽象类来包装/实现Callable
  2. 实现一个setter将结果“注入”到call()

定义一个抽象类:

import java.util.concurrent.Callable;

public abstract class Callback<T> implements Callable<Void> {
    T result;

    void setResult (T result) {
        this.result = result;
    }

    public abstract Void call ();
}

定义应触发回调的方法:

public void iWillFireTheCallback (Callback callback) {
    // You could also specify the signature like so:
    // Callback<Type of result> callback

    // make some information ("the result")
    // available to the callback function:
    callback.setResult("Some result");

    // fire the callback:
    callback.call();
}

在需要调用iWillFireTheCallback的地方:

定义回调函数(甚至可以在方法内部定义):

class MyCallback extends Callback {
    @Override
    public Void call () {
        // this is the actual callback function

        // the result variable is available right away:
        Log.d("Callback", "The result is: " + result);

        return null;
    }
}

然后在传递回调函数的同时调用iWillFireTheCallback

iWillFireTheCallback(new MyCallback());

1
这是我情况下的完美解决方案 :-D 谢谢! - peter_the_oak

8

补充Jarle的答案 - 如果您将 Callable 创建为匿名类的实例,则可以使用匿名类外部的 final 字段将数据传递到该实例:

<code><code>    final int arg = 64;
    executor.submit(new Callable<Integer>() {
        public Integer call() throws Exception {
            return arg * 2;
        }
    });
</code></code>

5

当您创建doPing类(类名应大写)时,请在构造函数中发送IP地址。在调用方法中使用此IP地址。


3

在你的 doPing 类中放置一些 (final) 字段,并且初始化它们,然后将你想要在 call() 中使用的值传递到 doPing 的构造函数中:

public class DoPing implements Callable<String>  {
     private final String ipToPing;

     public DoPing(String ip) {
         this.ipToPing = ip;
     }
     
     public String call() {
         // use ipToPing
     }
}

2

我知道回答这个问题已经非常晚了,考虑到它已经超过8年了,但最近15天仍然活跃,我觉得这对于使用Java 8及以上版本的人仍然有帮助。

PS,这只是Victor Sorokin答案中通过lambda实现的一种语法糖。

public static Callable<String> generateCallableWithArg(final String input) {
    return () -> {
      Thread.sleep(5000); // someExpensiveOperationHere
      return "Return Value of " + input; //input can be used here
    };
  }

此外,我们可以编写一个静态辅助方法,将函数转换为可调用对象(Callable)。
public class CallableGenerator {

  public static <T,V> Callable<V> getCallableFromFunction(Function<T, V> function, T input) {
    return () -> function.apply(input);
  }
}

这可以用作

Callable<Integer> iAmCallable = CallableGenerator.getCallableFromFunction(i1 -> i1 * 2, 3);

1
你需要定义一个属性,比如 ipAddress 和它的访问方法,并通过 constructor 或者 setter 方法来传递它的值。在 doPing 类中使用 ipAddress 属性。
class DoPing/* In java all classes start with capital letter */implements Callable<String>
{
    private String  ipAddress;

    public String getIpAddress()
    {
        return ipAddress;
    }

    public void setIpAddress(String ipAddress)
    {
        this.ipAddress = ipAddress;
    }

    /*
     * Counstructor 
     */
    public DoPing(String ipAddress )
    {
        this.ipAddress = ipAddress;
    }

    @Override
    public String call() throws Exception
    {
        // your logic
    }
}

0

并不总是可以引用(有效地)最终变量以使用其值作为“参数”,但您可以自己制定舒适的通用解决方案。首先定义此功能接口:

@FunctionalInteface
interface CallableFunction<T, R> {

    public abstract R call(T arg) throws Exception;

    public static <T, R> Callable<R> callable(CallableFunction<T, R> cf, T arg) {
        return () -> cf.call(arg);
    }
}

这个功能接口提供了一个静态方法 callable,它创建了一个 Callable 实例,该实例使用提供的参数(类型为 T)简单调用 call(T) 方法。然后,你需要让你的 DoPing 类来实现 CallableFunction 接口,就像这样:

public class DoPing implements CallableFunction<String, String> {

    @Override
    public String call(final String ipToPing) throws Exception {
        final var ipAddress = InetAddress.getByName(ipToPing);
        final var reachable = ipAddress.isReachable(1400);
        String pingOutput = null;
        if (reachable) {
            pingOutput = ipToPing + " is reachable.\n";
        }
        else {
            final var ping = Runtime.getRuntime().exec("ping " + ipToPing + " -n 1 -w 300");
            try (var in = new BufferedReader(new InputStreamReader(ping.getInputStream()))) {
                String line;
                for (int lineCount = 1; (line = in.readLine()) != null; ++lineCount) {
                    if (lineCount == 3) {
                        pingOutput = "Ping to " + ipToPing + ": " + line + "\n";
                        break;
                    }
                }
            }
        }
        return pingOutput;
    }

在这里,我们更改了 call 签名以接受 String 参数,并且现在它实现了 CallableFunction 而不是之前的 Callable。其他更改较小,但值得一提的是,我们通过使用 try-with-resource 在 BufferedReader 上防止了资源泄漏,并且还将输入收集循环中的 while 更改为 for 并添加了 break 以尽快终止。

现在您可以像这样使用该代码:

    final var ping = CallableFunction.callable(new DoPing(), "127.0.0.1");
    final var task = new FutureTask<>(ping);
    new Thread(task).start();
    System.out.println(task.get(20, TimeUnit.SECONDS));

当您需要时,您也可以在其他情况下重用CallableFunction


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接