Java 19[线程×，协程√]

1
2
3
4

// Go运行一个协程
go func() {
    fmt.Println("hello goroutine")
}()

1
2
3
4
5

// Java19通过Thread类静态方法启动一个线程，实际类型为Thread
Thread platformThread = Thread.ofPlatform().name("myPlatformThread").start(() -> System.out.println("hello platform thread"));

// Java19通过Thread类静态方法启动一个协程, 实际类型为VirtualThread
Thread virtualThread = Thread.ofVirtual().name("myVirtualThread").start(() -> System.out.println("hello virtual thread"));

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14

// 一、创建线程的ThreadFactory或则协程的ThreadFactory
ThreadFactory virtualFactory = Thread.ofVirtual().factory();
ThreadFactory platformFactory = Thread.ofPlatform().factory();
 
// 一、创建线程池或协程池
// 2.1、通过ThreadPoolExecutor带ThreadFactory参数的构造函数方式创建线程池或则协程池
new ThreadPoolExecutor(100, 1000, 60, TimeUnit.Second,
    new LinkedBlockingQueue<Runnable>(),
    virtualFactory, 
    (r, executor) -> System.out.println("塞不下了"));
 
// 2.2、通过Executors的静态方法创建，例如创建单一线程的线程池或单一协程的协程池
ExecutorService virtualExecutorService = Executors.newSingleThreadExecutor(virtualFactory);
ExecutorService platformExecutorService = Executors.newSingleThreadExecutor(platformFactory);

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17

AtomicInteger count = new AtomicInteger(0);
AtomicInteger nowInUse = new AtomicInteger(0);
AtomicInteger maxInUse = new AtomicInteger(0);
Runnable task = () -> {
    int[] stoarge = new int[1024];
    nowInUse.incrementAndGet();
    try {
        Thread.sleep(10);
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    }
    if (nowInUse.get() > maxInUse.get()) {
        maxInUse.set(nowInUse.get());
    }
    count.incrementAndGet();
    nowInUse.decrementAndGet();
};

1
2
3
4
5
6
7
8
9

var startTime = time.Now()
var nowInUseChan = make(chan int, 100)
task := func() {
    nowInUseChan <- 1
    defer func() {
        nowInUseChan <- -1
    }()
    time.Sleep(10)
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

# 测试样例1，执行2000次任务，全部执行，池化方式50核心线程数
➜  virtual git:(main) ✗ ./runMain.sh 2000 $((2#1111111)) 50
threads: 2000 type: 127 coreSize: 50
JAVA 开始
注: Main.java 使用 Java SE 19 的预览功能。
注: 有关详细信息，请使用 -Xlint:preview 重新编译。
threads: 2000   type: 1111111   coreSize: 50
-----------------THREAD-----------------
isVirtual: Y    final: 0s|77850 maxInUse: 1192
isVirtual: N    final: 0s|224622        maxInUse: 143
-----------------POOL_CACHED-----------------
isVirtual: Y    final: 0s|42432 maxInUse: 1652
isVirtual: N    final: 0s|162239        maxInUse: 501
-----------------POOL_FIXED-----------------
isVirtual: Y    final: 0s|492283        maxInUse: 50
isVirtual: N    final: 0s|476044        maxInUse: 50
-----------------POOL_PER-----------------
isVirtual: Y    final: 0s|17967 maxInUse: 2000
isVirtual: N    final: 0s|208582        maxInUse: 140
-----------------POOL_SCHEDULED-----------------
isVirtual: Y    final: 0s|475407        maxInUse: 50
isVirtual: N    final: 0s|479096        maxInUse: 50
-----------------POOL_SINGLE-----------------
isVirtual: Y    final: 22s|977343       maxInUse: 1
isVirtual: N    final: 22s|898969       maxInUse: 1
-----------------POOL_SINGLE_SCHEDULED-----------------
isVirtual: Y    final: 23s|79873        maxInUse: 1
isVirtual: N    final: 23s|35070        maxInUse: 1
GO 开始
-----------------GO Routine-----------------
isVirtual: Y    final: 0s|6043  maxInUse: 1948