Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for FakeOp (0.12 sec)

  1. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        class FakeOp implements Runnable {
          final int op;
    
          FakeOp(int op) {
            this.op = op;
          }
    
          @Override
          public void run() {
            callOrder.add(op);
          }
        }
    
        e.execute(new FakeOp(0));
        e.execute(new FakeOp(1));
        e.execute(new FakeOp(2));
        fakePool.runAll();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        class FakeOp implements Runnable {
          final int op;
    
          FakeOp(int op) {
            this.op = op;
          }
    
          @Override
          public void run() {
            callOrder.add(op);
          }
        }
    
        e.execute(new FakeOp(0));
        e.execute(new FakeOp(1));
        e.execute(new FakeOp(2));
        fakePool.runAll();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. cni/pkg/plugin/cnieventclient_test.go

    	Netns:       "someNetNS",
    	IfName:      "ethBro",
    	ContainerID: "bbb-eee-www",
    }
    
    var (
    	fakeIP                 = net.ParseIP("99.9.9.9")
    	fakeGW                 = net.ParseIP("88.9.9.9")
    	fakeIDX                = 0
    	fakePrevResultIPConfig = cniv1.IPConfig{
    		Interface: &fakeIDX,
    		Address: net.IPNet{
    			IP: fakeIP,
    		},
    		Gateway: fakeGW,
    	}
    )
    
    func TestPushCNIAddEventSucceed(t *testing.T) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

                } catch (InterruptedException ie) {
                  // continue
                }
                LockSupport.unpark(Thread.currentThread()); // simulate a spurious wakeup.
                return null;
              }
    
              @Override
              boolean isDone() {
                return false;
              }
    
              @Override
              String toPendingString() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        waiter1.interrupt();
    
        waiter1.join();
        waiter2.awaitWaiting(); // should still be blocked
    
        LockSupport.unpark(waiter2); // spurious wakeup
        waiter2.awaitWaiting(); // should eventually re-park
    
        future.set(null);
        waiter2.join();
      }
    
      public void testRemoveWaiter_polling() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
Back to top