Searched refs:qlock (Results 1 – 3 of 3) sorted by relevance
636 volatile int qlock; // 1: locked, -1: terminate; else 0 field in ForkJoinPool.WorkQueue970 qlock = 0; in externalPopAndExecCC()974 qlock = 0; in externalPopAndExecCC()1381 w.qlock = -1; // ensure set in deregisterWorker()1482 q.qlock = 0; in externalPush()1487 q.qlock = 0; in externalPush()1544 if (q.qlock == 0 && U.compareAndSwapInt(q, QLOCK, 0, 1)) { in fullExternalPush()1557 q.qlock = 0; // unlock in fullExternalPush()1719 if ((stat = w.qlock) >= 0 && w.eventCount == ec && ctl == c && in awaitWork()1726 stat = w.qlock = -1; // pool is terminating in awaitWork()[all …]
1127 private ReentrantLock qlock; field in SynchronousQueue1138 qlock = new ReentrantLock(true); in writeObject()1143 qlock = new ReentrantLock(); in writeObject()
1013 if (w != null && w.qlock < 0) in get()