我正在使用Java 8的新lambda功能,发现Java 8提供的实践确实很有用。但是,我想知道是否有一种 很好的 方法来解决以下情况。假设您有一个对象池包装器,需要某种工厂来填充对象池,例如(使用java.lang.functions.Factory):
java.lang.functions.Factory
public class JdbcConnectionPool extends ObjectPool<Connection> { public ConnectionPool(int maxConnections, String url) { super(new Factory<Connection>() { @Override public Connection make() { try { return DriverManager.getConnection(url); } catch ( SQLException ex ) { throw new RuntimeException(ex); } } }, maxConnections); } }
将功能接口转换为lambda表达式后,上面的代码变为:
public class JdbcConnectionPool extends ObjectPool<Connection> { public ConnectionPool(int maxConnections, String url) { super(() -> { try { return DriverManager.getConnection(url); } catch ( SQLException ex ) { throw new RuntimeException(ex); } }, maxConnections); } }
确实还算不错,但是检查的异常java.sql.SQLException需要在lambda内部加上try/ catch块。在我公司,我们长时间使用两个接口:
java.sql.SQLException
try
catch
IOut<T>
interface IUnsafeOut<T, E extends Throwable> { T out() throws E; }
这两个IOut<T>和IUnsafeOut<T>应该迁移到Java 8中被删除,但是不存在用于精确匹配IUnsafeOut<T, E>。如果lambda表达式可以像未检查的那样处理已检查的异常,则可以在上面的构造函数中像下面这样简单地使用它:
IUnsafeOut<T>
IUnsafeOut<T, E>
super(() -> DriverManager.getConnection(url), maxConnections);
看起来更干净了。我看到可以重写ObjectPool超类来接受我们的IUnsafeOut<T>,但是据我所知,Java 8尚未完成,因此可能会有一些变化,例如:
ObjectPool
Factory
javac
final
因此,问题通常是:有没有办法绕过lambda中的检查异常,还是在Java 8最终发布之前计划在将来进行?
更新1
嗯,据我所知,尽管参考文章的日期为2010年,但看来目前尚无办法:Brian Goetz解释了Java中的异常透明性。如果Java 8中没有太大变化,则可以认为是答案。Brian也说interface ExceptionalCallable<V, E extends Exception>(我在IUnsafeOut<T, E extends Throwable>代码遗留中提到的内容)几乎没有用,我同意他的观点。
interface ExceptionalCallable<V, E extends Exception>
IUnsafeOut<T, E extends Throwable>
我还想念其他东西吗?
不确定我是否真的回答了您的问题,但是您不能简单地使用类似的内容吗?
public final class SupplierUtils { private SupplierUtils() { } public static <T> Supplier<T> wrap(Callable<T> callable) { return () -> { try { return callable.call(); } catch (RuntimeException e) { throw e; } catch (Exception e) { throw new RuntimeException(e); } }; } } public class JdbcConnectionPool extends ObjectPool<Connection> { public JdbcConnectionPool(int maxConnections, String url) { super(SupplierUtils.wrap(() -> DriverManager.getConnection(url)), maxConnections); } }