AudioStreaming/AudioStreamingTests/Core/AtomicTests.swift

//
//  Created by Dimitrios Chatzieleftheriou on 22/05/2020.
//  Copyright © 2020 Decimal. All rights reserved.
//

import XCTest

@testable import AudioStreaming

class AtomicTests: XCTestCase {
    func testProtectedValuesAreAccessedSafely() {
        measure {
            let atomic = Atomic<Int>(0)

            DispatchQueue.concurrentPerform(iterations: 100_000) { _ in
                _ = atomic.value
                atomic.write { $0 += 1 }
            }

            XCTAssertEqual(atomic.value, 100_000)
        }
    }

    func testThatProtectedReadAndWriteAreSafe() {
        measure {
            let initialValue = "aValue"
            let protected = Atomic<String>(initialValue)

            DispatchQueue.concurrentPerform(iterations: 1000) { i in
                _ = protected.value
                protected.write { $0 = "\(i)" }
            }

            XCTAssertNotEqual(protected.value, initialValue)
        }
    }
}