Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for _popper (0.15 sec)

  1. src/runtime/mspanset.go

    		if block != nil {
    			// Check the popped value.
    			if block.popped.Load() == 0 {
    				// popped should never be zero because that means we have
    				// pushed at least one value but not yet popped if this
    				// block pointer is not nil.
    				throw("span set block with unpopped elements found in reset")
    			}
    			if block.popped.Load() == spanSetBlockEntries {
    				// popped should also never be equal to spanSetBlockEntries
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/testing/AbstractPackageSanityTests.java

        }
      }
    
      abstract static class Chopper {
    
        final Chopper or(Chopper you) {
          Chopper i = this;
          return new Chopper() {
            @Override
            Optional<String> chop(String str) {
              return i.chop(str).or(you.chop(str));
            }
          };
        }
    
        abstract Optional<String> chop(String str);
    
        static Chopper suffix(String suffix) {
          return new Chopper() {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  3. pkg/queue/delay_test.go

    		heap.Push(pq, task)
    	}
    
    	// dequeue should be in order
    	for i, task := range sorted {
    		peeked := pq.Peek()
    		popped := heap.Pop(pq)
    		if task != popped {
    			t.Fatalf("pop %d was not in order", i)
    		}
    		if peeked != popped {
    			t.Fatalf("did not peek at the next item to be popped")
    		}
    	}
    }
    
    func TestDelayQueueOrdering(t *testing.T) {
    	dq := NewDelayed(DelayQueueWorkers(2))
    	stop := make(chan struct{})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jul 20 06:27:31 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/testing/AbstractPackageSanityTests.java

        }
      }
    
      abstract static class Chopper {
    
        final Chopper or(Chopper you) {
          Chopper i = this;
          return new Chopper() {
            @Override
            Optional<String> chop(String str) {
              return i.chop(str).or(you.chop(str));
            }
          };
        }
    
        abstract Optional<String> chop(String str);
    
        static Chopper suffix(String suffix) {
          return new Chopper() {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  5. platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r70/TestDisplayNameJUnit5CrossVersionSpec.groovy

                                    test("throwsExceptionWhenPopped()") {
                                        operationDisplayName "throws EmptyStackException when popped"
                                        testDisplayName "throws EmptyStackException when popped"
                                    }
                                    testClass("org.example.TestingAStackDemo\$WhenNew\$AfterPushing") {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 16 10:10:39 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  6. platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/history/impl/FileSystemSnapshotSerializer.java

            }
    
            public List<FileSystemLocationSnapshot> pop() {
                List<FileSystemLocationSnapshot> popped = stack.pollLast();
                if (popped == null) {
                    throw new IllegalStateException("Stack empty");
                }
                return popped;
            }
        }
    
        private static String toAbsolutePath(Collection<String> parents, String fileName) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jan 26 15:45:55 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval.go

    // source can change over time - i.e. for watchCache circular
    // buffer. When the circular buffer is full and an event needs
    // to be popped off, watchCache::startIndex is incremented. In
    // this case, an interval tracking that popped event is valid
    // only if it has already been copied to its internal buffer.
    // However, for efficiency we perform that lazily and we mark
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  8. subprojects/core/src/test/groovy/org/gradle/internal/classpath/DefaultInstrumentedGroovyCallsTrackerTest.groovy

            then:
            thrown(IllegalStateException)
            instance.leaveCall(entryBar)
            instance.leaveCall(entryFoo)
    
            where:
            entryPointKind                 | index
            "has already been popped"      | 0
            "is still deeper in the stack" | 1
        }
    
        def 'throws an exception on instance.markCurrentCallAsIntercepted if its #part does not match'() {
            given:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Jul 24 15:57:59 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  9. platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/junit/platform/JUnitPlatformUserGuideIntegrationTest.groovy

            @Test
            @DisplayName("is empty")
            void isEmpty() {
                assertTrue(stack.isEmpty());
            }
    
            @Test
            @DisplayName("throws EmptyStackException when popped")
            void throwsExceptionWhenPopped() {
                assertThrows(EmptyStackException.class, () -> stack.pop());
            }
    
            @Nested
            @DisplayName("after pushing an element")
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Sep 18 20:52:40 UTC 2023
    - 12.7K bytes
    - Viewed (0)
  10. src/sync/pool_test.go

    					}
    				}
    			}
    			wg.Done()
    		}()
    	}
    
    	// Start 1 producer.
    	nPopHead := 0
    	wg.Add(1)
    	go func() {
    		for j := 0; j < N; j++ {
    			for !d.PushHead(j) {
    				// Allow a popper to run.
    				runtime.Gosched()
    			}
    			if j%10 == 0 {
    				val, ok := d.PopHead()
    				if ok {
    					nPopHead++
    					record(val.(int))
    				}
    			}
    		}
    		wg.Done()
    	}()
    	wg.Wait()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 8K bytes
    - Viewed (0)
Back to top