Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for WorkerState (0.16 sec)

  1. pkg/filewatcher/filewatcher.go

    }
    
    type fileWatcher struct {
    	mu sync.RWMutex
    
    	// The watcher maintain a map of workers,
    	// keyed by watched dir (parent dir of watched files).
    	workers map[string]*workerState
    
    	funcs *patchTable
    }
    
    type workerState struct {
    	worker *worker
    	count  int
    }
    
    // functions that can be replaced in a test setting
    type patchTable struct {
    	newWatcher     func() (*fsnotify.Watcher, error)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java

         */
        private interface WorkerState {
            void startWaitingForNextItem();
    
            void finishWaitingForNextItem();
        }
    
        /**
         * Implementations are only used by the worker thead and do not need to be thread safe.
         */
        private interface WorkerStats extends WorkerState {
            void startSelect();
    
            void finishSelect();
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 16:29:26 UTC 2024
    - 29.1K bytes
    - Viewed (0)
Back to top