Virtual threads

Signed-off-by: Eric Deandrea <[email protected]>
quarkusio · Jan 5, 2024 · 58d07f0 · 58d07f0
1 parent 073fd35
commit 58d07f0
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 7 deletions.
diff --git a/grpc-locations/pom.xml b/grpc-locations/pom.xml
@@ -160,7 +160,6 @@
         <artifactId>maven-surefire-plugin</artifactId>
         <version>${surefire-plugin.version}</version>
         <configuration>
-          <argLine>-Djdk.tracePinnedThreads</argLine>
           <systemPropertyVariables>
             <java.util.logging.manager>org.jboss.logmanager.LogManager</java.util.logging.manager>
             <maven.home>${maven.home}</maven.home>

diff --git a/...ations/src/main/kotlin/io/quarkus/sample/superheroes/location/grpc/LocationGrpcService.kt b/...ations/src/main/kotlin/io/quarkus/sample/superheroes/location/grpc/LocationGrpcService.kt
@@ -8,20 +8,17 @@ import io.quarkus.sample.superheroes.location.grpc.LocationsGrpc.LocationsImplBa
 import io.quarkus.sample.superheroes.location.mapping.LocationMapper
 import io.quarkus.sample.superheroes.location.service.LocationService
 import io.smallrye.common.annotation.Blocking
-import io.smallrye.common.annotation.RunOnVirtualThread
 
 @GrpcService
 class LocationGrpcService(private val locationService: LocationService) : LocationsImplBase() {
   @Blocking
-  @RunOnVirtualThread
   override fun getRandomLocation(request: RandomLocationRequest?, responseObserver: StreamObserver<Location>?) {
 		Log.debug("Requesting a random location")
 	  returnLocationOrError(this.locationService.getRandomLocation(), responseObserver)
 	  responseObserver?.onCompleted()
   }
 
 	@Blocking
-  @RunOnVirtualThread
 	override fun getLocationByName(request: GetLocationRequest?, responseObserver: StreamObserver<Location>?) {
 		if (request != null) {
 			Log.debug("Getting location ${request.name}")
@@ -32,7 +29,6 @@ class LocationGrpcService(private val locationService: LocationService) : Locati
 	}
 
 	@Blocking
-  @RunOnVirtualThread
 	override fun replaceAllLocations(request: LocationsList?, responseObserver: StreamObserver<ReplaceAllLocationsResponse>?) {
 		if (request != null) {
 			Log.debug("Replacing all locations")
@@ -47,7 +43,6 @@ class LocationGrpcService(private val locationService: LocationService) : Locati
 	}
 
 	@Blocking
-  @RunOnVirtualThread
 	override fun getAllLocations(request: AllLocationsRequest?, responseObserver: StreamObserver<LocationsList>?) {
 		val allLocations = this.locationService.getAllLocations()
 		Log.debug("Got all locations: $allLocations")
@@ -60,7 +55,6 @@ class LocationGrpcService(private val locationService: LocationService) : Locati
 	}
 
 	@Blocking
-  @RunOnVirtualThread
 	override fun deleteAllLocations(request: DeleteAllLocationsRequest?, responseObserver: StreamObserver<DeleteAllLocationsResponse>?) {
 		Log.debug("Deleting all locations")