Skip to content

⚡ Bolt: Offload blocking I/O to detached tasks to improve UI responsiveness #55

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
acebytes wants to merge 1 commit into
base: main
Choose a base branch
from
Open

⚡ Bolt: Offload blocking I/O to detached tasks to improve UI responsiveness #55

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
26 changes: 18 additions & 8 deletions Sources/Cacheout/ViewModels/CacheoutViewModel.swift
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -147,7 +147,10 @@ class CacheoutViewModel: ObservableObject {
func scan() async {
isScanning = true
isNodeModulesScanning = true
diskInfo = DiskInfo.current()

// ⚡ Bolt: Offload synchronous file system call to prevent blocking the @MainActor
// Impact: Keeps the UI responsive (avoiding a ~5-10ms hitch) during initial scan
diskInfo = await Task.detached { DiskInfo.current() }.value

// Scan caches and node_modules in parallel
async let cacheResults = scanner.scanAll(CacheCategory.allCategories)
Expand Down Expand Up @@ -241,12 +244,18 @@ class CacheoutViewModel: ObservableObject {
]

do {
try process.run()
process.waitUntilExit()
let data = pipe.fileHandleForReading.readDataToEndOfFile()
let output = String(data: data, encoding: .utf8) ?? ""

if process.terminationStatus == 0 {
// ⚡ Bolt: Offload blocking I/O (process.run, waitUntilExit, readDataToEndOfFile)
// Impact: Prevents the @MainActor from freezing during the entire Docker prune execution,
// which can take several seconds to complete. Keeps the UI completely responsive.
let (output, terminationStatus) = try await Task.detached {
try process.run()
process.waitUntilExit()
let data = pipe.fileHandleForReading.readDataToEndOfFile()
let output = String(data: data, encoding: .utf8) ?? ""
return (output, process.terminationStatus)
}.value

if terminationStatus == 0 {
// Extract "Total reclaimed space:" line
if let line = output.components(separatedBy: "\n")
.first(where: { $0.contains("reclaimed") }) {
Expand All @@ -270,7 +279,8 @@ class CacheoutViewModel: ObservableObject {
}

// Refresh disk info after prune
diskInfo = DiskInfo.current()
// ⚡ Bolt: Offload synchronous file system call
diskInfo = await Task.detached { DiskInfo.current() }.value
}

func clean() async {
Expand Down