wip,new!: complete revision. names and structure of program items was changed

Author: sttk

pom.xml

@@ -4,7 +4,7 @@
   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
 
-  <groupId>com.github.sttk</groupId>
+  <groupId>io.github.sttk</groupId>
   <artifactId>sabi</artifactId>
   <version>0.4.0</version>
   <packaging>jar</packaging>
@@ -47,6 +47,12 @@
   </properties>
 
   <dependencies>
+    <dependency>
+      <groupId>io.github.sttk</groupId>
+      <artifactId>errs</artifactId>
+      <version>0.1.0</version>
+      <scope>compile</scope>
+    </dependency>
     <dependency>
       <groupId>org.junit.jupiter</groupId>
       <artifactId>junit-jupiter</artifactId>

src/main/java/com/github/sttk/sabi/AsyncGroup.java

@@ -4,71 +4,14 @@
  */
 package com.github.sttk.sabi;
 
+import com.github.sttk.errs.Exc;
+
 import java.util.Map;
 import java.util.HashMap;
 
-/**
- * Manages multiple asynchronous runner and allows for waiting until all runners have completed.
- * It also handles error collection to store errors that encounter during executions.
- */
-public class AsyncGroup {
-
-  /** Is a reason which indicates that a runner has failed during execution. */
-  public record RunnerFailed() {}
-
-  /** Is a reason which indicates that a runner was interrupted during execution. */
-  public record RunnerInterrupted() {}
-
-  /** Map to store errors associated with each asynchronous runner by name. */
-  private Map<String, Err> errMap = new HashMap<>();
-
-  /** Map to store virtual threads associated with each asynchronous runner by name. */
-  private Map<String, Thread> vthMap = new HashMap<>();
-
-  /** Name associated with the group of asynchronous runner. */
-  public String name;
-
-  /**
-   * Is the default constructor.
-   */
-  AsyncGroup() {}
-
-  /**
-   * Adds a new asynchronous operation to this instance.
-   * The operation is provided as a function that returns an {@link Err}.
-   * If the function encounters an error, it is recorded internally.
-   *
-   * @param runner  The runner task to be executed asynchronously.
-   */
-  public void add(final Runner runner) {
-    final var name = this.name;
-    var vth = Thread.ofVirtual().start(() -> {
-      try {
-        runner.run();
-      } catch (Err | RuntimeException e) {
-        addErr(name, e);
-      }
-    });
-    vthMap.put(name, vth);
-  }
-
-  synchronized void addErr(String name, Exception exc) {
-    if (exc instanceof Err) {
-      errMap.put(name, Err.class.cast(exc));
-    } else {
-      errMap.put(name, new Err(new RunnerFailed(), exc));
-    }
-  }
-
-  Map<String, Err> join() {
-    for (var ent : vthMap.entrySet()) {
-      try {
-        ent.getValue().join();
-      } catch (InterruptedException e) {
-        addErr(ent.getKey(), new Err(new RunnerInterrupted(), e));
-      }
-    }
+public interface AsyncGroup {
+  record RunnerFailed() {}
+  record RunnerInterrupted() {}
 
-    return errMap;
-  }
+  void add(final Runner runner);
 }

src/main/java/com/github/sttk/sabi/DataConn.java

@@ -0,0 +1,17 @@
+/*
+ * DataConn class.
+ * Copyright (C) 2022-2025 Takayuki Sato. All Rights Reserved.
+ */
+package com.github.sttk.sabi;
+
+import com.github.sttk.errs.Exc;
+
+public interface DataConn {
+  void commit(AsyncGroup ag) throws Exc;
+  void preCommit(AsyncGroup ag) throws Exc;
+  void postCommit(AsyncGroup ag);
+  boolean shouldForceBack();
+  void rollback(AsyncGroup ag);
+  void forceBack(AsyncGroup ag);
+  void close();
+}

src/main/java/com/github/sttk/sabi/DataSrc.java

@@ -0,0 +1,13 @@
+/*
+ * DataSrc class.
+ * Copyright (C) 2022-2025 Takayuki Sato. All Rights Reserved.
+ */
+package com.github.sttk.sabi;
+
+import com.github.sttk.errs.Exc;
+
+public interface DataSrc {
+  void setup(AsyncGroup ag) throws Exc;
+  void close();
+  DataConn createDataConn() throws Exc;
+}