(Extension DC 2025) Actor境界を越える技術

ͻΊ͠!FYUFOTJPO%$ "DUPSڥքΛӽ͑Δٕज़ ɹɹ,8%$ొஃใࠂ actor boundary를 넘어서 / KWDC25 발표
보고

1VMTF$PEF.PEVMBUJPO 1$. ৼ෯ ࣌ؒ v 0 v 1 v 2
v 3 v 4 v 5 v 6 v 7 v 8 v 9 v 10 v 11 var soundData: [Float]

"7"VEJP4PVSDF/PEF let frequency: Float = 440 let sampleRate: Float =
48_000 var phase: Float = 0 var sourceNode: AVAudioSourceNode { AVAudioSourceNode { [self] _, _, frameCount, outputPointer in guard let outputBuffer = outputPointer.pointee.mBuffers.mData? .assumingMemoryBound(to: Float.self) else { return kAudioUnitErr_Uninitialized } for index in 0..<Int(frameCount) { outputBuffer[index] = sin(phase) // Set the amplitude phase += 2 * .pi * frequency / sampleRate // Increment phase } return noErr } }

"DUPSͰҐ૬Λอ࣋ actor SineWavePlayer { var phase: Float = 0 var
sourceNode: AVAudioSourceNode { AVAudioSourceNode { ... } } func play() throws { phases = 0 let audioEngine = AVAudioEngine() let sourceNode = sourceNode audioEngine.attach(sourceNode) audioEngine.connect(sourceNode, to: audioEngine.mainMixerNode, format: ...) audioEngine.prepare() try audioEngine.start() } }

ऴ ੍࡞ɾஶ࡞ ͻ Ί ͠

EJTQBUDI@BTTFSU@RVFVF@GBJM

ࠓ೔ͷΰʔϧ ΫϥογϡͷཧղɺղܾΛ௨ͯ͡ 4XJGU$PODVSSFODZʹ͓͚Δ ࠷৽ͷಉظΞΫηεͷٕज़ΛֶͿ

w "DUPSDPOUFYUʹ͍ͭͯͷ෮श w ΫϥογϡΛཧղ͢Δ w ಉظతΞΫηεͷͨΊͷٕज़ w $VTUPNBDUPSFYFDVUPS w .VUFY
໨࣍

"DUPSDPOUFYU "DUPS" var a: Int = 42 func foo() var
b: Int = 123 "DUPS" "DUPS# ࣌ؒ bar() getter B Actor B bar() (Other) func bar() ಉظ ඇಉظ

એݴɾΫϩʔδϟʔͱ"DUPSDPOUFYU actor MyActor { var value: Int = 42 var
nonSendableBlock: () -> Void { // Assumed to be executed on MyActor's context { [self] in value = value + 1 } } }

actor MyActor { var value: Int = 42 var nonSendableBlock:
() -> Void { // Assumed to be executed on MyActor's context { [self] in value = value + 1 } } var sendableBlock: @Sendable () -> Void { // Cannot touch MyActor's property synchronously { /* [self] in value = value + 1 */ } } } એݴɾΫϩʔδϟʔͱ"DUPSDPOUFYU

actor MyActor { var value: Int = 42 var nonSendableBlock:
() -> Void { // Assumed to be executed on MyActor's context { [self] in value = value + 1 } } var sendableBlock: @Sendable () -> Void { // Cannot touch MyActor's property synchronously { /* [self] in value = value + 1 */ } } nonisolated var nonisolatedBlock: () -> Void { // Cannot touch MyActor's property synchronously { /* [self] in value = value + 1 */ } } } એݴɾΫϩʔδϟʔͱ"DUPSDPOUFYU

໨࣍

"7'"VEJPͷߏ੒ཁૉ "QQMJDBUJPO "7"VEJP&OHJOF "7"VEJP 4PVSDF/PEF 4ZTUFN "VEJP1SPDFTT "UUBDI ఆظతʹ ݺͼग़͠
Ի੠σʔλ Λܭࢉ

"7'"VEJPͷߏ੒ཁૉ "QQMJDBUJPO "7"VEJP&OHJOF "7"VEJP 4PVSDF/PEF 4ZTUFN "VEJP1SPDFTT "UUBDI ఆظతʹ ݺͼग़͠
Ի੠σʔλ Λܭࢉ γεςϜͷΦʔσΟΦॲཧ εϨουͰ࣮ߦ͞ΕΔ

"7"VEJP4PVSDF/PEF3FOEFS#MPDL typealias AVAudioSourceNodeRenderBlock = ( UnsafeMutablePointer<ObjCBool>, // isSilence UnsafePointer<AudioTimeStamp>, //
timestamp AVAudioFrameCount, // frameCount UnsafeMutablePointer<AudioBufferList> // outputData ) -> OSStatus @Sendable͕ͳ͍4FOEBCMFͳΫϩʔδϟͰ͸ͳ͍

࣮ߦ"DUPSDPOUFYUҧ൓ w 4PVOESFOEFSJOHCMPDL͸4JOF8BWF1MBZFSBDUPSʹଐ͢Δɻ 4JOF8BWF1MBZFSͷBDUPSDPOUFYU্Ͱ࣮ߦ͞ΕΔ΂͖ɻ w ͔࣮͠͠ࡍʹ͸ɺ4PVOESFOEFSJOHCMPDL͸γεςϜͷΦʔσΟ Φॲཧ༻εϨου্Ͱ࣮ߦ͞ΕΔɻ BDUPS4JOF8BWF1MBZFS var phase:
Float "7"VEJP4PVSDF/PEF 3FOEFSCMPDL 3FOEFSCMPDL 4ZTUFN"VEJP5ISFBE $BQUVSFE

4XJGUͰͷϥϯλΠϜݕࠪ w 4XJGUͰ͸ɺظ଴͞ΕͨBDUPS্Ͱίʔυ͕࣮ߦ͞Ε͍ͯΔ͔ ࣮ߦ࣌ʹݕࠪ͞ΕΔɻ w ҟͳΔBDUPS্Ͱίʔυ͕࣮ߦ͞Εͨ৔߹ɺΫϥογϡ͢Δɻ

ͦΕͰ΋ಉظؔ਺Ͱ͋Δඞཁ͕͋Δ actor SineWavePlayer { var phase: Float = 0 nonisolated
var sourceNode: AVAudioSourceNode { AVAudioSourceNode { [self] _, _, frameCount, outputPointer in guard let outputBuffer = outputPointer.pointee.mBuffers.mData? .assumingMemoryBound(to: Float.self) else { return kAudioUnitErr_Uninitialized } for index in 0..<Int(frameCount) { outputBuffer[index] = sin(phase) // Set the amplitude phase += 2 * .pi * frequency / sampleRate // Increment phase } return noErr } } } Actor-isolated property 'phase' can not be   referenced from a nonisolated context

ҟͳΔBDUPSDPOUFYU্ͷϓϩύςΟʹ ಉظతʹΞΫηε͍ͨ͠ɻ

໨࣍

actor MyActor { func sample() async { funcA() await funcB()
funcC() await funcD() funcE() } } actor MyActor { } &YFDVUPS Job Job Job Job Job Job "DUPS+PCͷ࣮ߦ

$VTUPNBDUPSFYFDVUPS w +PCFYFDVUPSΛࣗ෼Ͱ࣮૷ͯ͠ࢦఆ͢Δɻ w l͍ͭzɺzͲ͜Ͱz+PCΛ࣮ߦ͢Δ͔ΛίϯτϩʔϧͰ͖Δɻ w SerialExecutorϓϩτίϧʹ४ڌͨ͠+PCFYFDVUPSΛ࣮૷ ͢Δɻ w "DUPSͷunownedExecutorϓϩύςΟΛઃఆ͢Δɻ

BDUPS4JOF8BWF1MBZFS var phase: Float "7"VEJP4PVSDF/PEF 3FOEFSCMPDL 4ZTUFN"VEJP5ISFBE 3FOEFSCMPDL 4ZODISPOPVT "DDFTT
$BQUVSFE %JTQBUDI2VFVFͰ"DUPSΛ͚ͬͭ͘Δ w BDUPSͷδϣϒΛ%JTQBUDI2VFVFͰ࣮ߦɻ w TPVOESFOEFSJOHCMPDL΋%JTQBUDI2VFVFͰ࣮ߦɻ

%JTQBUDI2VFVF BDUPS4JOF8BWF1MBZFS var phase: Float "7"VEJP4PVSDF/PEF 3FOEFSCMPDL 4ZTUFN"VEJP5ISFBE 3FOEFSCMPDL 4ZODISPOPVT
"DDFTT $BQUVSFE %JTQBUDI2VFVFͰ"DUPSΛ͚ͬͭ͘Δ w BDUPSͷδϣϒΛ%JTQBUDI2VFVFͰ࣮ߦɻ w TPVOESFOEFSJOHCMPDL΋%JTQBUDI2VFVFͰ࣮ߦɻ

%JTQBUDI2VFVF w BDUPSͷδϣϒΛ%JTQBUDI2VFVFͰ࣮ߦɻ w TPVOESFOEFSJOHCMPDL΋%JTQBUDI2VFVFͰ࣮ߦɻ BDUPS4JOF8BWF1MBZFS var phase: Float "7"VEJP4PVSDF/PEF
3FOEFSCMPDL 4ZTUFN"VEJP5ISFBE 3FOEFSCMPDL 4ZODISPOPVT "DDFTT $BQUVSFE %JTQBUDI2VFVFͰ"DUPSΛ͚ͬͭ͘Δ

&YFDVUPSͷ࣮૷ final class PlayerExecutor: @unchecked Sendable, SerialExecutor { let queue
= DispatchQueue(label: "Player") func enqueue(_ job: consuming ExecutorJob) { let unownedSelf = asUnownedSerialExecutor() let unownedJob = UnownedJob(job) queue.async { unownedJob.runSynchronously(on: unownedSelf) } } func checkIsolated() { dispatchPrecondition(condition: .onQueue(queue)) } }

final class PlayerExecutor: @unchecked Sendable, SerialExecutor { let queue =
DispatchQueue(label: "Player") func enqueue(_ job: consuming ExecutorJob) { let unownedSelf = asUnownedSerialExecutor() let unownedJob = UnownedJob(job) queue.async { unownedJob.runSynchronously(on: unownedSelf) } } func checkIsolated() { dispatchPrecondition(condition: .onQueue(queue)) } } &YFDVUPSͷ࣮૷

final class PlayerExecutor: @unchecked Sendable, SerialExecutor { let queue =
DispatchQueue(label: "Player") func enqueue(_ job: consuming ExecutorJob) { let unownedSelf = asUnownedSerialExecutor() let unownedJob = UnownedJob(job) queue.async { unownedJob.runSynchronously(on: unownedSelf) } } func checkIsolated() { dispatchPrecondition(condition: .onQueue(queue)) } } queueͷ֎Ͱݺ͹ΕΔͱΫϥογϡ͢Δ &YFDVUPSͷ࣮૷

&YFDVUPSΛࢦఆ actor SineWavePlayer { let executor = PlayerExecutor() nonisolated var
unownedExecutor: UnownedSerialExecutor { executor.asUnownedSerialExecutor() } }

%JTQBUDI2VFVF BDUPS4JOF8BWF1MBZFS var phase: Float "7"VEJP4PVSDF/PEF 3FOEFSCMPDL 4ZTUFN"VEJP5ISFBE 3FOEFSCMPDL 4ZODISPOPVT
"DDFTT $BQUVSFE %JTQBUDI2VFVFͰ"DUPSΛ͚ͬͭ͘Δ w BDUPSͷδϣϒΛ%JTQBUDI2VFVFͰ࣮ߦɻ w TPVOESFOEFSJOHCMPDL΋%JTQBUDI2VFVFͰ࣮ߦɻ

%JTQBUDI2VFVF্Ͱ4PVOESFOEFSJOH var sourceNode: AVAudioSourceNode { AVAudioSourceNode { [executor] _, _,
frameCount, outputPointer in executor.queue.sync { [weak self] in guard let self else { return noErr } guard let outputBuffer = outputPointer.pointee.mBuffers.mData? .assumingMemoryBound(to: Float.self) else { return kAudioUnitErr_Uninitialized } for index in 0..<Int(frameCount) { outputBuffer[index] = sin(self.phase) // Set the amplitude self.phase += 2 * .pi * frequency / sampleRate // Increment phase } return noErr } } }

4PVOESFOEFSJOHMPHJDΛִ཭͢Δ var sourceNode: AVAudioSourceNode { AVAudioSourceNode { [executor] _, _,
frameCount, outputPointer in executor.queue.sync { [weak self] in guard let self else { return noErr } return assumeIsolated { this in guard let outputBuffer = outputPointer.pointee.mBuffers.mData? .assumingMemoryBound(to: Float.self) else { return kAudioUnitErr_Uninitialized } for index in 0..<Int(frameCount) { outputBuffer[index] = sin(this.phase) // Set the amplitude this.phase += 2 * .pi * frequency / sampleRate // Increment phase } return noErr } } } }

%JTQBUDI2VFVF w શͯΛ%JTQBUDI2VFVF্ͰγϦΞϧʢ௚ྻʣʹ࣮ߦ͢Δɻ w assumeIsolatedΛ༻͍ͯಉ͡BDUPSDPOUFYUʹॴଐͤ͞Δɻ BDUPS4JOF8BWF1MBZFS var phase: Float "7"VEJP4PVSDF/PEF
3FOEFSCMPDL 4ZTUFN"VEJP5ISFBE 3FOEFSCMPDL 4ZODISPOPVT "DDFTT $BQUVSFE %JTQBUDI2VFVFͰ"DUPSΛ͚ͬͭ͘Δ

໨࣍

.VUFY w withLock಺ͷίʔυ͕ഉଞతʹ࣮ߦ͞ΕΔɻ w εϨουΛϒϩοΫͯ͠଴ػ͢Δɻ w 4XJGUDPODVSSFODZͱͷ૊Έ߹Θͤʹ͸஫ҙΛཁ͢Δɻ w 4FOEBCMFɻ"DUPSڥքΛӽ͑ͯΞΫηεͰ͖Δɻ let
myValue = Mutex<Int>(42) myValue.withLock { $0 = 123 }

.VUFYͰҐ૬ม਺ʹΞΫηε͢Δ DMBTT4JOF8BWF1MBZFS let phase: Mutex<Float> "7"VEJP4PVSDF/PEF 3FOEFSCMPDL 4ZTUFN"VEJP5ISFBE $BQUVSFE w
ΦʔσΟΦॲཧ༻εϨου͔Β.VUFYʹ௚઀ΞΫηε͢Δɻ w 4PVOESFOEFSJOHCMPDLશମΛ.VUFYͰϩοΫ͢Δɻ 4JOF8BWF1MBZFS

class SineWavePlayer { let phase = Mutex<Float>(0) var sourceNode: AVAudioSourceNode
{ AVAudioSourceNode { [self] _, _, frameCount, outputPointer in phase.withLock { phase in guard let outputBuffer = outputPointer.pointee.mBuffers.mData? .assumingMemoryBound(to: Float.self) else { return kAudioUnitErr_Uninitialized } for index in 0..<Int(frameCount) { outputBuffer[index] = sin(phase) // Set the amplitude phase += 2 * .pi * frequency / sampleRate // Increment phase } return noErr } } } } .VUFYʹΑΔ࣮૷

.VUFYʹΑΔ࣮૷ class SineWavePlayer { let phase = Mutex<Float>(0) var sourceNode:
AVAudioSourceNode { AVAudioSourceNode { [self] _, _, frameCount, outputPointer in phase.withLock { phase in guard let outputBuffer = outputPointer.pointee.mBuffers.mData? .assumingMemoryBound(to: Float.self) else { return kAudioUnitErr_Uninitialized } for index in 0..<Int(frameCount) { outputBuffer[index] = sin(phase) // Set the amplitude phase += 2 * .pi * frequency / sampleRate // Increment phase } return noErr } } } }

XJUI-PDLͱॲཧͷΞτϛοΫੑ class SineWavePlayer: Sendable { let phase = Mutex<Float>(0) var
sourceNode: AVAudioSourceNode { AVAudioSourceNode { [self] _, _, frameCount, outputPointer in guard let outputBuffer = outputPointer.pointee.mBuffers.mData? .assumingMemoryBound(to: Float.self) else { return kAudioUnitErr_Uninitialized } for index in 0..<Int(frameCount) { phase.withLock { outputBuffer[index] = sin($0) } phase.withLock { $0 += 2 * .pi * frequency / sampleRate } } return noErr } } }

·ͱΊ w ҟͳΔBDUPSDPOUFYU্ͷϓϩύςΟʹಉظతʹΞΫηε͢Δ ඞཁ͕͋Δ͜ͱ͕͋Δɻ w $VTUPNBDUPSFYFDVUPSʹΑͬͯɺҟͳΔBDUPSDPOUFYUΛҰͭ ʹϚʔδ͢Δ͜ͱ͕Ͱ͖Δɻ w .VUFYΛ࢖͏ͱɺঢ়ଶม਺͸ҟͳΔBDUPSDPOUFYU͔Β௚઀ ΞΫηεՄೳʹͳΔɻ

ͭͷํ๏ͷൺֱ $VTUPNBDUPS FYFDVUPS .VUFY ࣮૷ͷ؆୯͞ !͋Δఔ౓४උ͕ඞཁ "ม਺Λஔ͖׵͑Δ͚ͩ 4XJGUDPODVSSFODZ ͱͷ౷߹ "͍ͭ΋ͷ
BTZODBXBJUελΠϧ ⚠ΞτϛοΫੑͱ σουϩοΫʹཁ஫ҙ

,8%$ w ೥݄೔ι΢ϧʹͯ։࠵͞Εͨ "QQMFϓϥοτϑΥʔϜ։ൃऀͷࠃࡍΧϯϑΝϨϯεɻ w γϯάϧτϥοΫɺ೔։࠵ɻࠓ೥Ͱճ໨ɻ w ొஃऀਓதɺ೔ຊ͔Βਓɻ w ࢀՃऀͱͯ͠͸೔ຊ͔Β૯੎ਓ͙Β͍ʁ
w ଞʹதࠃຊ౔ɺγϯΨϙʔϧɺΧφμ౳͔Βདྷ͍ͯͨɻ w 'MJUUPʹΑΔ຋༁αʔϏε׬උɻ

(Extension DC 2025) Actor境界を越える技術

(Extension DC 2025) Actor境界を越える技術

More Decks by Himeshi

Other Decks in Programming

Featured

Transcript