File tree Expand file tree Collapse file tree 2 files changed +6
-4
lines changed
opengrok-web/src/main/java/org/opengrok/web/api/v1/controller Expand file tree Collapse file tree 2 files changed +6
-4
lines changed Original file line number Diff line number Diff line change 34
34
import java .util .Map ;
35
35
import java .util .Set ;
36
36
import java .util .TreeSet ;
37
+ import java .util .concurrent .CompletableFuture ;
37
38
import java .util .logging .Level ;
38
39
import java .util .logging .Logger ;
39
40
import java .util .stream .Collectors ;
@@ -206,7 +207,7 @@ public void deleteProjectData(@PathParam("project") String projectNameParam) {
206
207
deleteHistoryCache (projectName );
207
208
208
209
// Delete suggester data.
209
- new Thread (() -> suggester .delete (projectName )). start ( );
210
+ CompletableFuture . runAsync (() -> suggester .delete (projectName ));
210
211
}
211
212
212
213
@ DELETE
@@ -273,7 +274,7 @@ public void markIndexed(@PathParam("project") String projectNameParam) throws Ex
273
274
}
274
275
}
275
276
276
- new Thread (() -> suggester .rebuild (projectName )). start ( );
277
+ CompletableFuture . runAsync (() -> suggester .rebuild (projectName ));
277
278
278
279
// In case this project has just been incrementally indexed,
279
280
// its IndexSearcher needs a poke.
Original file line number Diff line number Diff line change 69
69
import java .util .List ;
70
70
import java .util .Map ;
71
71
import java .util .Map .Entry ;
72
+ import java .util .concurrent .CompletableFuture ;
72
73
import java .util .logging .Level ;
73
74
import java .util .logging .Logger ;
74
75
import java .util .stream .Collectors ;
@@ -173,13 +174,13 @@ public SuggesterConfig getConfig() {
173
174
@ PUT
174
175
@ Path ("/rebuild" )
175
176
public void rebuild () {
176
- new Thread (() -> suggester .rebuild ()). start ( );
177
+ CompletableFuture . runAsync (() -> suggester .rebuild ());
177
178
}
178
179
179
180
@ PUT
180
181
@ Path ("/rebuild/{project}" )
181
182
public void rebuild (@ PathParam ("project" ) final String project ) {
182
- new Thread (() -> suggester .rebuild (project )). start ( );
183
+ CompletableFuture . runAsync (() -> suggester .rebuild (project ));
183
184
}
184
185
185
186
/**
You can’t perform that action at this time.
0 commit comments