java quasar实现纤程完整代码实例

àì夳堔傛蜴生んèń 2023-10-06 07:18 37阅读 0赞

pom：

<project xmlns = "http://maven.apache.org/POM/4.0.0"
        xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation = "http://maven.apache.org/POM/4.0.0
        http://maven.apache.org/xsd/maven-4.0.0.xsd">
     
        
        <modelVersion>4.0.0</modelVersion>
        
        <groupId>com.zxl</groupId>
     
        
        <artifactId>hello-quasar</artifactId>
     
        
        <version>1.0</version>
    
        
        
    
        <dependencies>
            
            <dependency>
                <groupId>co.paralleluniverse</groupId>
                <artifactId>quasar-core</artifactId>
                <version>0.7.5</version>
            </dependency>
    
        </dependencies>
    
        <build>
            <plugins>
    
                
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-assembly-plugin</artifactId>
                    <executions>
                        <execution>
                            <phase>package</phase>
                            <goals>
                                <goal>single</goal>
                            </goals>
                            <configuration>
                                <archive>
                                <manifest>
                                    <mainClass>
                                        com.zxl.quasar.HelloFiberMsb
                                    </mainClass>
                                </manifest>
                                </archive>
                                <descriptorRefs>
                                    <descriptorRef>jar-with-dependencies</descriptorRef>
                                </descriptorRefs>
                            </configuration>
                        </execution>
                    </executions>
                </plugin>
    
    
                
                
                
            </plugins>
        </build>
    
    </project>

java代码：

package com.zxl.quasar;
    import co.paralleluniverse.fibers.Fiber;
    import co.paralleluniverse.fibers.SuspendExecution;
    import co.paralleluniverse.strands.SuspendableRunnable;
    
    public class HelloFiberMsb {
        public static void main(String[] args) {
            System.out.println("===================================");
            long start = System.currentTimeMillis();
            for (int k = 0; k < 10000; k++) {
                Fiber<Void> fiber = new Fiber<Void>(new SuspendableRunnable(){
                    public void run() throws SuspendExecution,InterruptedException{
                        calc();
                    }
                });
                fiber.start();
            }
            long end = System.currentTimeMillis();
            System.out.println(end - start);
        }
    
        static void calc(){
            int result = 0;
            for (int i = 0; i < 10000; i++) {
                for (int j = 0; j < 200; j++) {
                    result+=j;
                }
            }
        }
    }

测试：要用到javaagent

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200502223902557.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2E3NzIzMDQ0MTk=,size_16,color_FFFFFF,t_70