Merge pull request #5583 from lorentey/sr-3106.closure-benchmarks

[benchmark][SR-3106] Add benchmarks with 4 different Observers

Author: gottesmm

benchmark/CMakeLists.txt

@@ -64,6 +64,10 @@ set(SWIFT_BENCH_MODULES
     single-source/NSStringConversion
     single-source/NopDeinit
     single-source/ObjectAllocation
+    single-source/ObserverClosure
+    single-source/ObserverForwarderStruct
+    single-source/ObserverPartiallyAppliedMethod 
+    single-source/ObserverUnappliedMethod 
     single-source/OpenClose
     single-source/Phonebook
     single-source/PolymorphicCalls

benchmark/single-source/ObserverClosure.swift

@@ -0,0 +1,29 @@
+
+class Observer {
+  @inline(never)
+  func receive(_ value: Int) {
+  }
+}
+
+class Signal {
+  var observers: [(Int) -> ()] = []
+
+  func subscribe(_ observer: @escaping (Int) -> ()) {
+    observers.append(observer)
+  }
+
+  func send(_ value: Int) {
+    for observer in observers {
+      observer(value)
+    }
+  }
+}
+
+public func run_ObserverClosure(_ iterations: Int) {
+  let signal = Signal()
+  let observer = Observer()
+  for _ in 0 ..< 10_000 * iterations {
+    signal.subscribe { i in observer.receive(i) }
+  }
+  signal.send(1)
+}

benchmark/single-source/ObserverForwarderStruct.swift

@@ -0,0 +1,41 @@
+
+class Observer {
+  @inline(never)
+  func receive(_ value: Int) {
+  }
+}
+
+protocol Sink {
+  func receive(_ value: Int)
+}
+
+struct Forwarder: Sink {
+  let object: Observer
+
+  func receive(_ value: Int) {
+    object.receive(value)
+  }
+}
+
+class Signal {
+  var observers: [Sink] = []
+
+  func subscribe(_ sink: Sink) {
+    observers.append(sink)
+  }
+
+  func send(_ value: Int) {
+    for observer in observers {
+      observer.receive(value)
+    }
+  }
+}
+
+public func run_ObserverForwarderStruct(_ iterations: Int) {
+  let signal = Signal()
+  let observer = Observer()
+  for _ in 0 ..< 10_000 * iterations {
+    signal.subscribe(Forwarder(object: observer))
+  }
+  signal.send(1)
+}

benchmark/single-source/ObserverPartiallyAppliedMethod.swift

@@ -0,0 +1,29 @@
+
+class Observer {
+  @inline(never)
+  func receive(_ value: Int) {
+  }
+}
+
+class Signal {
+  var observers: [(Int) -> ()] = []
+
+  func subscribe(_ observer: @escaping (Int) -> ()) {
+    observers.append(observer)
+  }
+
+  func send(_ value: Int) {
+    for observer in observers {
+      observer(value)
+    }
+  }
+}
+
+public func run_ObserverPartiallyAppliedMethod(_ iterations: Int) {
+  let signal = Signal()
+  let observer = Observer()
+  for _ in 0 ..< 10_000 * iterations {
+    signal.subscribe(observer.receive)
+  }
+  signal.send(1)
+}

benchmark/single-source/ObserverUnappliedMethod.swift

@@ -0,0 +1,43 @@
+
+class Observer {
+  @inline(never)
+  func receive(_ value: Int) {
+  }
+}
+
+protocol Sink {
+  func receive(_ value: Int)
+}
+
+struct Forwarder<Object>: Sink {
+  let object: Object
+  let method: (Object) -> (Int) -> ()
+
+  func receive(_ value: Int) {
+    method(object)(value)
+  }
+}
+
+class Signal {
+  var observers: [Sink] = []
+
+  func subscribe(_ sink: Sink) {
+    observers.append(sink)
+  }
+
+  func send(_ value: Int) {
+    for observer in observers {
+      observer.receive(value)
+    }
+  }
+}
+
+public func run_ObserverUnappliedMethod(_ iterations: Int) {
+  let signal = Signal()
+  let observer = Observer()
+  for _ in 0 ..< 10_000 * iterations {
+    let forwarder = Forwarder(object: observer, method: Observer.receive)
+    signal.subscribe(forwarder)
+  }
+  signal.send(1)
+}

benchmark/utils/main.swift

@@ -68,6 +68,10 @@ import ObjectAllocation
 import ObjectiveCBridging
 import ObjectiveCBridgingStubs
 import ObjectiveCNoBridgingStubs
+import ObserverClosure
+import ObserverForwarderStruct
+import ObserverPartiallyAppliedMethod
+import ObserverUnappliedMethod
 import OpenClose
 import Phonebook
 import PolymorphicCalls
@@ -197,6 +201,10 @@ precommitTests = [
   "ObjectiveCBridgeToNSDictionary": run_ObjectiveCBridgeToNSDictionary,
   "ObjectiveCBridgeToNSSet": run_ObjectiveCBridgeToNSSet,
   "ObjectiveCBridgeToNSString": run_ObjectiveCBridgeToNSString,
+  "ObserverClosure": run_ObserverClosure,
+  "ObserverForwarderStruct": run_ObserverForwarderStruct,
+  "ObserverPartiallyAppliedMethod": run_ObserverPartiallyAppliedMethod,
+  "ObserverUnappliedMethod": run_ObserverUnappliedMethod,
   "OpenClose": run_OpenClose,
   "Phonebook": run_Phonebook,
   "PolymorphicCalls": run_PolymorphicCalls,