er

wer

e

wer

er

wer

wer

wer

wer

Author: Kasper Nielsen

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/SchedulingContext.java

@@ -1,13 +1,13 @@
 package app.packed.concurrent;
 
-import app.packed.bean.scanning.BeanTrigger.OnContextServiceVariable;
+import app.packed.bean.scanning.BeanTrigger.AutoInject;
 import app.packed.concurrent.job2.JobExtension;
 import app.packed.context.Context;
 
 /**
  * A context object available for scheduling.
  */
-@OnContextServiceVariable(introspector = JobExtension.MyI.class, requiresContext = SchedulingContext.class)
+@AutoInject(introspector = JobExtension.MyI.class, requiresContext = SchedulingContext.class)
 public interface SchedulingContext extends Context<JobExtension> {
 
     /** {@return cancel future invocation of the scheduled operations. In progress operations will be allowed to finish} */

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/annotations/ScheduledJobContext.java

@@ -1,10 +1,10 @@
 package app.packed.concurrent.annotations;
 
-import app.packed.bean.scanning.BeanTrigger.OnContextServiceVariable;
+import app.packed.bean.scanning.BeanTrigger.AutoInject;
 import app.packed.concurrent.other.ScheduledJobExtension;
 import app.packed.context.Context;
 
-@OnContextServiceVariable(introspector = ScheduledJobExtension.ScheduledJobBeanIntrospector.class, requiresContext = ScheduledJobContext.class)
+@AutoInject(introspector = ScheduledJobExtension.ScheduledJobBeanIntrospector.class, requiresContext = ScheduledJobContext.class)
 public interface ScheduledJobContext extends Context<ScheduledJobExtension> {
 
     void pause();

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/DaemonJob.java

@@ -15,14 +15,20 @@
  */
 package app.packed.concurrent.job;
 
+import java.lang.annotation.Annotation;
 import java.lang.annotation.ElementType;
 import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
+import java.util.concurrent.TimeUnit;
 
+import app.packed.bean.scanning.BeanIntrospector;
 import app.packed.bean.scanning.BeanTrigger.OnAnnotatedMethod;
+import app.packed.binding.Key;
 import app.packed.concurrent.ThreadKind;
-import internal.app.packed.concurrent.daemon.JobBeanintrospector;
+import app.packed.concurrent.job.DaemonJob.Daemonintrospector;
+import app.packed.extension.BaseExtension;
+import internal.app.packed.concurrent.daemon.DaemonOperationHandle;
 
 /**
  * Will have a dedicated thread.
@@ -46,7 +52,7 @@
 // SupportJob
 @Target(ElementType.METHOD)
 @Retention(RetentionPolicy.RUNTIME)
-@OnAnnotatedMethod(allowInvoke = true, introspector = JobBeanintrospector.class)
+@OnAnnotatedMethod(allowInvoke = true, introspector = Daemonintrospector.class)
 public @interface DaemonJob {
 
     String startup() default "When-exactly-are we starting";
@@ -71,4 +77,39 @@
      * @see DaemonMirror#threadKind()
      */
     ThreadKind threadKind() default ThreadKind.DAEMON_THREAD;
+
+    final class Daemonintrospector extends BeanIntrospector<BaseExtension> {
+
+        /** {@inheritDoc} */
+        @Override
+        public void onAnnotatedMethod(Annotation annotation, BeanIntrospector.OnMethod method) {
+            if (annotation instanceof DaemonJob daemon) {
+                DaemonOperationHandle.installFromAnnotation(this, method, daemon);
+            } else {
+                super.onAnnotatedMethod(annotation, method);
+            }
+        }
+
+        /** {@inheritDoc} */
+        @Override
+        public void onExtensionService(Key<?> key, OnContextService service) {
+            if (service.matchNoQualifiers(DaemonJobContext.class)) {
+                service.binder().bindInvocationArgument(1);
+            } else {
+                super.onExtensionService(key, service);
+            }
+        }
+    }
 }
+//Could return, RESTART, EXIT, SLEEP, CONTINUE
+
+//Tror det er noget den annoterede metode kan returnere
+
+interface DaemonJobAction {
+
+ // The one problem here is cleanup...
+ // Do we want a stop method? Probably not
+ static DaemonJobAction sleep(long duration, TimeUnit timeUnit) {
+     throw new UnsupportedOperationException();
+ }
+}

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/DaemonJobContext.java

@@ -17,19 +17,18 @@
 
 import java.util.concurrent.TimeUnit;
 
-import app.packed.bean.scanning.BeanTrigger.OnContextServiceVariable;
+import app.packed.bean.scanning.BeanTrigger.AutoInject;
 import app.packed.context.Context;
 import app.packed.extension.BaseExtension;
-import internal.app.packed.concurrent.daemon.DaemonRuntimeOperationRunner.PackedDaemonContext;
-import internal.app.packed.concurrent.daemon.JobBeanintrospector;
+import internal.app.packed.concurrent.daemon.DaemonSideBean;
 
 /**
  * A context object that can be injected into daemon methods.
  *
  */
 // I think we need a bit understand about where we are in the shutdown process, early, vs late
-@OnContextServiceVariable(introspector = JobBeanintrospector.class, requiresContext = DaemonJobContext.class)
-public sealed interface DaemonJobContext extends Context<BaseExtension> permits PackedDaemonContext {
+@AutoInject(introspector = DaemonJob.Daemonintrospector.class, requiresContext = DaemonJobContext.class)
+public sealed interface DaemonJobContext extends Context<BaseExtension> permits DaemonSideBean {
 
     /**
      * @return

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/DaemonJobMirror.java

@@ -26,7 +26,7 @@
  */
 public final class DaemonJobMirror extends JobMirror {
 
-    final DaemonOperationHandle handle;
+    private final DaemonOperationHandle handle;
 
     /**
      * @param handle

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/JobMirror.java

@@ -25,6 +25,7 @@
 public abstract class JobMirror extends OperationMirror {
 
     OperationHandle<?> handle;
+
     /**
      * @param handle
      */

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/README.md

@@ -1,8 +1,8 @@
 ==== A job is typically adds a bit more overhead to the task, than simply using a ExecutorService ====
 * A job has a unique name within a namespace
 * A job can have a context injected
-* The status of a job can be tracked in JobTracker
-* A job can be tagged 
+* The status of a job can be tracked in a JobTracker
+* A job can be tagged (operations)
 
 
 

modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/ScTest2.java

@@ -37,7 +37,7 @@ public static void main(String[] args) throws Exception {
 //        });
 
         App.run(new ScTest2());
-        Thread.sleep(1000);
+        Thread.sleep(10000);
     }
 
     /** {@inheritDoc} */

…va/app/packed/concurrent/job/JobApp.java …pp/packed/concurrent/job/app/JobApp.javamodules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/JobApp.java renamed to modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/app/JobApp.java modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/JobApp.java renamed to modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/app/JobApp.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package app.packed.concurrent.job;
+package app.packed.concurrent.job.app;
 
 import java.util.concurrent.Future;
 

…/packed/concurrent/job/PackedJobApp.java …ked/concurrent/job/app/PackedJobApp.javamodules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/PackedJobApp.java renamed to modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/app/PackedJobApp.java modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/PackedJobApp.java renamed to modules/packed-incubator/packed-incubator-concurrent/src/main/java/app/packed/concurrent/job/app/PackedJobApp.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package app.packed.concurrent.job;
+package app.packed.concurrent.job.app;
 
 import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;