11

在使用 Java 7 try-with-resources 语句实现 anAutoCloseable时，我想知道 try 块中是否存在异常。例如：

class C implements AutoCloseable {
    @Override
    public void close() {
        if (exceptionOccurred)
            something();
        else
            somethingElse();
    }
}

为了说明这一点：

try (C c = new C()) {

    // This should cause a call to "something()"
    if (something)
        throw new RuntimeException();

    // This should cause a call to "somethingElse()"
    else
        ;
}

现在，从了解try-with-resources 语句如何转换为 bytecode，我想这是不可能的。但是是否有任何（可靠的！）技巧通过检测/反射/一些未记录的编译器功能允许我RuntimeException从内部访问上述内容AutoCloseable.close()？

注意：我是 API 设计人员，我无法控制 API 使用者的 try-with-resources 代码。因此必须在AutoCloseable现场进行实施

4

2 回答 2

10

执行此操作的正常方法是在 try 块的末尾显式调用。例如：

try (CustomTransaction transaction = ...) {
    // Do something which might throw an exception...

    transaction.commitOnClose();
}

然后在 中close，您要么中止事务，要么提交事务，这取决于是否commitOnClose()已被调用。

它不是自动的，但实现起来非常简单 - 并且非常易于阅读。

于 2014-01-25T17:14:28.270 回答
2

我已经为此苦苦挣扎了一段时间。我不喜欢 Jon Skeet 的回答，因为开发人员（即我）可能会不小心忘记调用commitOnClose(). 我想要一种让开发人员在离开代码块时被迫调用 commit() 或 rollback() 的方法。

Lambda 和检查的异常不能很好地结合在一起，所以一个合适的解决方案有点令人费解，但最终我和我的一个同事想出了一段代码，让你可以像这样工作：

TransactionEnforcer.DbResult<String> result = transactionEnforcer.execute(db -> {
  try {
    db.someFunctionThatThrowsACheckedException();
  } catch (TheException e) {
    return failure("fallback value");
  }
  return success(db.getAFancyValue());
});

result.ifPresent(v -> System.out.println(v));

请注意如何返回值，检查代码是否成功，并且 java 的代码路径返回检查强制您始终明确说明是否应提交代码。

它是使用下面的代码实现的：

package nl.knaw.huygens.timbuctoo.database;

import java.util.Optional;
import java.util.function.Function;
import java.util.function.Supplier;

public class TransactionEnforcer {
  private final Supplier<DbClass> dbClassFactory;

  public TransactionEnforcer(Supplier<DbClass> dbClassFactory) {
    this.dbClassFactory = dbClassFactory;
  }

  public <U> DbResult<U> execute(Function<DbClass, DbResult<U>> actions) {
    DbClass db = dbClassFactory.get();
    try {
      DbResult<U> result = actions.apply(db);
      if (result.isSuccess()) {
        db.close(true);
      } else {
        db.close(false);
      }
      return result;
    } catch (RuntimeException e) {
      db.close(false);
      throw e;
    }
  }

  public static class DbResult<T> {
    private final Optional<T> value;
    private final boolean success;

    private DbResult(T value, boolean success) {
      this.value = Optional.of(value);
      this.success = success;
    }

    public static <T> DbResult<T> success(T value) {
      return new DbResult<T>(value, true);
    }

    public static <T> DbResult<T> success() {
      return new DbResult<T>(null, true);
    }

    public static <T> DbResult<T> failure(T value) {
      return new DbResult<T>(value, false);
    }

    public static <T> DbResult<T> failure() {
      return new DbResult<T>(null, false);
    }

    public boolean isSuccess() {
      return success;
    }

    public Optional<T> getValue() {
      return value;
    }
  }
}

（我将 DbClass 作为练习留给读者）

于 2016-09-23T13:23:27.277 回答