Browse Source

Merge branch 'feature_gufengshou_20240125_pid'

gufengshou1 1 year ago
parent
commit
a2928fe55e

+ 3 - 0
ad-engine-service/src/main/java/com/tzld/piaoquan/ad/engine/service/score/container/PidLambdaContainer.java

@@ -97,6 +97,7 @@ public class PidLambdaContainer {
             InputStreamReader isr=new InputStreamReader(is);
             BufferedReader bufferedReader = new BufferedReader(isr);
             String line = null;
+            ConcurrentHashMap<Long,Double>  temp=new ConcurrentHashMap<>();
             while ((line = bufferedReader.readLine()) != null){
                 try {
                     String[] cols=line.split(",");
@@ -120,6 +121,8 @@ public class PidLambdaContainer {
                     e.printStackTrace();
                 }
             }
+            lambdaCache.clear();
+            lambdaCache=temp;
         }catch (Exception e){
             log.error("svc=calNewLambda status=failed error={}", Arrays.toString(e.getStackTrace()));
         }