feat: Increase maximum concurrent requests for the server to 1000 (#138)

* increase threads to 1000

Author: kappratiksha

.github/workflows/conformance.yml

@@ -27,15 +27,22 @@ jobs:
     - name: Bundle install
       run: 'bundle install'
     - name: Run HTTP conformance tests
-      uses: GoogleCloudPlatform/functions-framework-conformance/action@v1.4.1
+      uses: GoogleCloudPlatform/functions-framework-conformance/action@v1.6.0
       with:
         functionType: 'http'
         useBuildpacks: false
         cmd: "'bundle exec functions-framework-ruby --source test/conformance/app.rb --target http_func --signature-type http'"
     - name: Run CloudEvent conformance tests
-      uses: GoogleCloudPlatform/functions-framework-conformance/action@v1.4.1
+      uses: GoogleCloudPlatform/functions-framework-conformance/action@v1.6.0
       with:
         functionType: 'cloudevent'
         useBuildpacks: false
         validateMapping: true
         cmd: "'bundle exec functions-framework-ruby --source test/conformance/app.rb --target cloudevent_func --signature-type cloudevent'"
+    - name: Run HTTP concurrency tests
+      uses: GoogleCloudPlatform/functions-framework-conformance/[email protected]
+      with:
+        functionType: 'http'
+        useBuildpacks: false
+        validateConcurrency: true
+        cmd: "'bundle exec functions-framework-ruby --source test/conformance/app.rb --target concurrent_http_func --signature-type http'"

.github/workflows/unit.yml

@@ -49,7 +49,7 @@ jobs:
     - name: Checkout repo
       uses: actions/checkout@v2
     - name: Install Ruby ${{ matrix.ruby }}
-      uses: ruby/setup-ruby@v1
+      uses: ruby/setup-ruby@v1.112.0
       with:
         ruby-version: "${{ matrix.ruby }}"
     - name: Install dependencies

lib/functions_framework/server.rb

@@ -306,7 +306,7 @@ def min_threads
       # @return [Integer]
       #
       def max_threads
-        @max_threads || 8
+        @max_threads || 1024
       end
 
       ##

test/conformance/app.rb

@@ -21,3 +21,8 @@
   result = json_format.encode_event event: event
   File.write OUTPUT_FILE, result[:content]
 end
+
+FunctionsFramework.http "concurrent_http_func" do
+  sleep 1
+  "ok"
+end