Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for NewPriorityQueue (0.33 sec)

  1. pkg/scheduler/internal/queue/testing.go

    }
    
    func NewTestQueueWithInformerFactory(
    	ctx context.Context,
    	lessFn framework.LessFunc,
    	informerFactory informers.SharedInformerFactory,
    	opts ...Option,
    ) *PriorityQueue {
    	pq := NewPriorityQueue(lessFn, informerFactory, opts...)
    	informerFactory.Start(ctx.Done())
    	informerFactory.WaitForCacheSync(ctx.Done())
    	return pq
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 10 00:53:58 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/collection/CollectionsUtil.java

         *
         * @param <E>
         *            {@link PriorityQueue}の要素型
         * @return {@link PriorityQueue}の新しいインスタンス
         * @see PriorityQueue#PriorityQueue()
         */
        public static <E> PriorityQueue<E> newPriorityQueue() {
            return new PriorityQueue<>();
        }
    
        /**
         * {@link PriorityQueue}の新しいインスタンスを作成して返します。
         *
         * @param <E>
         *            {@link PriorityQueue}の要素型
    Registered: Wed Jun 12 12:50:12 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 53.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/Queues.java

       *     in 15.0)
       */
      @SuppressWarnings("rawtypes") // https://github.com/google/guava/issues/989
      public static <E extends Comparable> PriorityQueue<E> newPriorityQueue() {
        return new PriorityQueue<>();
      }
    
      /**
       * Creates a {@code PriorityQueue} containing the given elements.
       *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 16K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/Queues.java

       *     in 15.0)
       */
      @SuppressWarnings("rawtypes") // https://github.com/google/guava/issues/989
      public static <E extends Comparable> PriorityQueue<E> newPriorityQueue() {
        return new PriorityQueue<>();
      }
    
      /**
       * Creates a {@code PriorityQueue} containing the given elements.
       *
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 18K bytes
    - Viewed (0)
  5. pkg/scheduler/scheduler_test.go

    			podInformer := informerFactory.Core().V1().Pods()
    			// Need to add/update/delete testPod to the store.
    			podInformer.Informer().GetStore().Add(testPod)
    
    			queue := internalqueue.NewPriorityQueue(nil, informerFactory, internalqueue.WithClock(testingclock.NewFakeClock(time.Now())))
    			schedulerCache := internalcache.New(ctx, 30*time.Second)
    
    			if err := queue.Add(logger, testPod); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/queue/scheduling_queue.go

    	return &framework.QueuedPodInfo{
    		PodInfo:              &framework.PodInfo{Pod: pod},
    		UnschedulablePlugins: sets.New(plugins...),
    	}
    }
    
    // NewPriorityQueue creates a PriorityQueue object.
    func NewPriorityQueue(
    	lessFn framework.LessFunc,
    	informerFactory informers.SharedInformerFactory,
    	opts ...Option,
    ) *PriorityQueue {
    	options := defaultPriorityQueueOptions
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/queue/scheduling_queue_test.go

    			cs := fake.NewSimpleClientset(tt.podInfo.Pod)
    			informerFactory := informers.NewSharedInformerFactory(cs, 0)
    			podLister := informerFactory.Core().V1().Pods().Lister()
    
    			// Build a PriorityQueue.
    			q := NewPriorityQueue(newDefaultQueueSort(), informerFactory, WithPodLister(podLister))
    			ctx, cancel := context.WithCancel(context.Background())
    			defer cancel()
    			informerFactory.Start(ctx.Done())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
Back to top