更新

.idea/workspace.xml

@@ -6,11 +6,8 @@
   <component name="ChangeListManager">
     <list default="true" id="4f7dccd9-8f92-4a6e-90cc-33890d102263" name="Changes" comment="Changes">
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/concurrency/IntelligentRecognitionProcess.py" beforeDir="false" afterPath="$PROJECT_DIR$/concurrency/IntelligentRecognitionProcess.py" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/concurrency/PullVideoStreamProcess.py" beforeDir="false" afterPath="$PROJECT_DIR$/concurrency/PullVideoStreamProcess.py" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/config/dsp_application.json" beforeDir="false" afterPath="$PROJECT_DIR$/config/dsp_application.json" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/service/Dispatcher.py" beforeDir="false" afterPath="$PROJECT_DIR$/service/Dispatcher.py" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/test/内存优化/slots/test1.py" beforeDir="false" afterPath="$PROJECT_DIR$/test/内存优化/slots/test1.py" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/util/CpuUtils.py" beforeDir="false" afterPath="$PROJECT_DIR$/util/CpuUtils.py" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -129,29 +126,29 @@
     <option name="hideEmptyMiddlePackages" value="true" />
     <option name="showLibraryContents" value="true" />
   </component>
-  <component name="PropertiesComponent"><![CDATA[{
-  "keyToString": {
-    "RunOnceActivity.OpenProjectViewOnStart": "true",
-    "RunOnceActivity.ShowReadmeOnStart": "true",
-    "WebServerToolWindowFactoryState": "true",
-    "WebServerToolWindowPanel.toolwindow.highlight.mappings": "true",
-    "WebServerToolWindowPanel.toolwindow.highlight.symlinks": "true",
-    "WebServerToolWindowPanel.toolwindow.show.date": "false",
-    "WebServerToolWindowPanel.toolwindow.show.permissions": "false",
-    "WebServerToolWindowPanel.toolwindow.show.size": "false",
-    "last_opened_file_path": "D:/tuoheng/code1/alg_aaa/streamTool",
-    "node.js.detected.package.eslint": "true",
-    "node.js.detected.package.tslint": "true",
-    "node.js.selected.package.eslint": "(autodetect)",
-    "node.js.selected.package.tslint": "(autodetect)",
-    "nodejs_package_manager_path": "npm",
-    "project.structure.last.edited": "SDK",
-    "project.structure.proportion": "0.15",
-    "project.structure.side.proportion": "0.2816092",
-    "settings.editor.selected.configurable": "http.proxy",
-    "vue.rearranger.settings.migration": "true"
+  <component name="PropertiesComponent">{
+  &quot;keyToString&quot;: {
+    &quot;RunOnceActivity.OpenProjectViewOnStart&quot;: &quot;true&quot;,
+    &quot;RunOnceActivity.ShowReadmeOnStart&quot;: &quot;true&quot;,
+    &quot;WebServerToolWindowFactoryState&quot;: &quot;true&quot;,
+    &quot;WebServerToolWindowPanel.toolwindow.highlight.mappings&quot;: &quot;true&quot;,
+    &quot;WebServerToolWindowPanel.toolwindow.highlight.symlinks&quot;: &quot;true&quot;,
+    &quot;WebServerToolWindowPanel.toolwindow.show.date&quot;: &quot;false&quot;,
+    &quot;WebServerToolWindowPanel.toolwindow.show.permissions&quot;: &quot;false&quot;,
+    &quot;WebServerToolWindowPanel.toolwindow.show.size&quot;: &quot;false&quot;,
+    &quot;last_opened_file_path&quot;: &quot;D:/tuoheng/code1/alg_aaa/streamTool&quot;,
+    &quot;node.js.detected.package.eslint&quot;: &quot;true&quot;,
+    &quot;node.js.detected.package.tslint&quot;: &quot;true&quot;,
+    &quot;node.js.selected.package.eslint&quot;: &quot;(autodetect)&quot;,
+    &quot;node.js.selected.package.tslint&quot;: &quot;(autodetect)&quot;,
+    &quot;nodejs_package_manager_path&quot;: &quot;npm&quot;,
+    &quot;project.structure.last.edited&quot;: &quot;SDK&quot;,
+    &quot;project.structure.proportion&quot;: &quot;0.15&quot;,
+    &quot;project.structure.side.proportion&quot;: &quot;0.2816092&quot;,
+    &quot;settings.editor.selected.configurable&quot;: &quot;preferences.pluginManager&quot;,
+    &quot;vue.rearranger.settings.migration&quot;: &quot;true&quot;
   }
-}]]></component>
+}</component>
   <component name="RecentsManager">
     <key name="CopyFile.RECENT_KEYS">
       <recent name="D:\tuoheng\codenew\tuoheng_alg\entity" />
@@ -529,7 +526,8 @@
       <workItem from="1687308509659" duration="25425000" />
       <workItem from="1687652018398" duration="8524000" />
       <workItem from="1687736740408" duration="603000" />
-      <workItem from="1687737713032" duration="3021000" />
+      <workItem from="1687737713032" duration="3837000" />
+      <workItem from="1687779451916" duration="1653000" />
     </task>
     <servers />
   </component>

config/dsp_application.json

@@ -108,6 +108,9 @@
   },
   "model": {
     "limit": 3
+  },
+  "task": {
+    "limit": 5
   }
 }
 

service/Dispatcher.py

@@ -349,7 +349,7 @@ class DispatcherService:
 
     def online(self, message, analysisType):
         if "start" == message.get("command"):
-            if self.__resource_status or len(self.__listeningProcesses) >= 5:
+            if self.__resource_status or len(self.__listeningProcesses) >= int(self.__context["task"]["limit"]):
                 raise ServiceException(ExceptionType.NO_RESOURCES.value[0],
                                        ExceptionType.NO_RESOURCES.value[1])
             self.startOnlineProcess(message, analysisType)
@@ -360,7 +360,7 @@ class DispatcherService:
 
     def offline(self, message, analysisType):
         if "start" == message.get("command"):
-            if self.__resource_status or len(self.__listeningProcesses) >= 5:
+            if self.__resource_status or len(self.__listeningProcesses) >= int(self.__context["task"]["limit"]):
                 raise ServiceException(ExceptionType.NO_RESOURCES.value[0],
                                        ExceptionType.NO_RESOURCES.value[1])
             self.startOfflineProcess(message, analysisType)